在java中怎样创建MySQL数据库列表 给个例子
发布网友
发布时间：2022-04-25 12:59
共2个回答
懂视网
时间：2022-05-01 20:17
public static final String url = "jdbc:mysql://localhost:3306/school?useUnicode=true&characterEncoding=UTF-8"; //连接数据库的URL地址
public static String username = "root"; //数据库的用户名
public static String password = ""; //数据库的密码
public static Connection conn=null;//连接对象
public static Statement stmt=null;//语句
public static ResultSet rs = null;//结果集
//1.加载MySQL数据库驱动
static
{
try {
Class.forName("com.mysql.jdbc.Driver");
//2、建立数据库连接
conn = (Connection) DriverManager.getConnection(url,username,password);
if(conn != null)
{
System.out.println("数据库连接正常");
}
else
{
System.out.println("数据库连接失败");
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
//查询所有的学生资料
public static void query()
{
String sql = "select * from students;";
try {
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
while(rs.next())
{
System.out.println("学号："+rs.getInt("sid")+",姓名："+rs.getString("sname")+",年龄:"+rs.getInt("age")+",性别："+rs.getString("gender"));
}
} catch (Exception e)
{
e.printStackTrace();
}
finally
{
destoryResource();
}
}
//添加学生方法
public static boolean add()
{
String sql = "insert into Students values (11,‘张三天‘,138,‘f‘,‘zhangsan@qq.com‘,‘广州阳江‘);";
try
{
stmt = conn.createStatement();
int result = stmt.executeUpdate(sql);
if(result > 0)
{
System.out.println("数据添加成功");
return true;
}
else
{
System.out.println("数据库添加失败");
return false;
}
}
catch(Exception ex)
{
ex.printStackTrace();
return false;
}
finally
{
destoryResource();
}
}
//释放资源的方法
public static void destoryResource()
{
try {
if(rs != null)
{
rs.close();
rs = null;
}
if (stmt != null)
{
stmt.close();
stmt = null;
}
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
//释放最后资源
public static void destoryallResource()
{
try
{
if (conn != null)
{
conn.close();
conn = null;
}
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
//删除指定学号的学生资料
public static boolean delete(int sid)
{
String sql = "delete from students where sid="+sid;
try
{
stmt = conn.createStatement();
int result = stmt.executeUpdate(sql);
if(result>0)
{
System.out.println("数据添删除成功");
return true;
}
else
{
System.out.println("数据添没有删除");
return false;
}
}
catch(Exception ex)
{
ex.printStackTrace();
return false;
}
finally
{
destoryResource();
}
}
//修改所有学生的年龄为20岁
public static boolean update(int age)
{
String sql = "update students set age="+age;
try
{
stmt = conn.createStatement();
int result = stmt.executeUpdate(sql);
if(result>0)
{
return true;
}
else
{
return false;
}
}
catch(Exception ex)
{
ex.printStackTrace();
return false;
}
finally
{
destoryResource();
}
}
public static void main(String[] args)
{
jdbc02.query(); //查询语句
if (jdbc02.add())
{
System.out.println("添加成功！");
}
else
{
System.out.println("添加失败！");
}
System.out.println("---------------------");
jdbc02.query();
jdbc02.delete(11);
System.out.println("------删除学号为11的学生之后--------");
jdbc02.query();
jdbc02.update(20);
System.out.println("------修改所有学生年龄为20岁--------");
jdbc02.query();
jdbc02.destoryallResource(); //释放资源
}
}
本文出自 “知止内明” 博客，请务必保留此出处http://357712148.blog.51cto.com/6440370/1894631
Java操作mysql数据库简单例子
标签：java操作mysql例子
热心网友
时间：2022-05-01 17:25
需要使用jdbc访问数据库。
具体步骤如下：
1：加载驱动
，返回连接
private
static
final
String
DRIVER_CLASS
=
"com.mysql.jdbc.Driver";
private
static
final
String
DATABASE_URL
=
"jdbc:mysql://localhost:3306/student";
private
static
final
String
DATABASE_USRE
=
"root";
private
static
final
String
DATABASE_PASSWORD
=
"cs";
/**
*
返回连接
*
*
@return
Connection
*/
public
static
Connection
getConnection()
{
Connection
dbConnection
=
null;
try
{
Class.forName(DRIVER_CLASS);
dbConnection
=
DriverManager.getConnection(DATABASE_URL,
DATABASE_USRE,
DATABASE_PASSWORD);
}
catch
(Exception
e)
{
e.printStackTrace();
}
return
dbConnection;
}
2：获取连接，执行sql语句
public
static
List
selectAllStudent()
{
Connection
con
=
null;
PreparedStatement
pstm
=
null;
ResultSet
rs
=
null;
List
list
=
new
ArrayList();
String
sql
=
"select
*
from
Student
";
try
{
con
=
ConnectionManager.getConnection();
pstm
=
con.prepareStatement(sql);
//
pstm.setString(1,
uname);
rs
=
pstm.executeQuery();
while
(rs.next())
{
Student
model
=
new
Student();
model.setStuId(rs.getInt("stuId"));
list.add(model);
}
}
catch
(SQLException
e)
{
e.printStackTrace();
}
finally
{
ConnectionManager.closeResultSet(rs);
ConnectionManager.closeStatement(pstm);
ConnectionManager.closeConnection(con);
}
return
list;
}
3：调用获取列表方法。
