JDBC简单使用
2023-12-20 15:13:10
1. 首先导包,放在src -> lib下
打开项目结构,添加导入的包为库
基础语法
Statement statement = conn.createStatement();
----------------------------------------------
1.execute(String query)方法用来执行任意的SQL语句查询,如果查询的结果是一个ResultSet,这个方法就返回true,
如果结果不是ResultSet,比如:insert或update,就会返回false.可以通过getResultSet方法来获取ResultSet。
2.executeQuery(String query)接口用来执行select查询,并返回ResultSet,
即便查询不到记录,返回的ResultSet也不会为null.
3.executeUpdate(String query)方法用来执行insert,delete或者update语句,返回值是int类型,
如果是DML语句,则是更新的条数,如果是DDL,则返回0
普通使用
private String connStr = "jdbc:mysql://localhost:3306/red1";
private String user = "root";
private String pwd = "123456";
//依赖
Class.forName("com.mysql.cj.jdbc.Driver");
//获得连接
Connection conn = DriverManager.getConnection(connStr, user, pwd);
Statement statement = conn.createStatement();
//sql语句
String sql="select * from table";
//执行查询操作
statement.execute(sql);
//关闭数据库连接
statement.close();
conn.close();
新增
public void addKeShi(String str1, String str2) throws ClassNotFoundException, SQLException {
//获得连接
Connection conn = DriverManager.getConnection(connStr, user, pwd);
Statement statement = conn.createStatement();
//sql
String sql = "INSERT INTO ke_shi(name,describe1) VALUES ('" + str1 + "','" + str2 + "')";
// System.out.println(sql);
int num = statement.executeUpdate(sql);
if (num == 1) {
System.out.println("科室新增成功\n");
} else {
System.out.println("科室新增失败,SQL语句为:" + sql + "\n");
}
//关闭数据库连接
statement.close();
conn.close();
}
查询所有
public List<KeShi> getAllKeShi() throws ClassNotFoundException, SQLException {
//获得连接
Connection conn = DriverManager.getConnection(connStr, user, pwd);
Statement statement = conn.createStatement();
//sql
String sql = "SELECT * FROM ke_shi";
ResultSet rs = statement.executeQuery(sql);
List<KeShi> list = new ArrayList<>();
KeShi keShi=null;
while (rs.next()) {
//获取当前记录中的数据
//方法1. 通过字段索引获取id,列索引是从1开始的。
int id = rs.getInt(1);
String name = rs.getString(2);
String describe = rs.getString(3);
keShi=new KeShi(id,name,describe);
list.add(keShi);
}
//关闭数据库连接
statement.close();
conn.close();
return list;
}
修改
public void changeKeShiByID(int id, String str1, String str2) throws ClassNotFoundException, SQLException {
//获得连接
Connection conn = DriverManager.getConnection(connStr, user, pwd);
Statement statement = conn.createStatement();
//sql
String sql = "UPDATE ke_shi SET name='" + str1 + "',describe1='" + str2 + "' WHERE id = " + id;
// System.out.println(sql);
int num = statement.executeUpdate(sql);
if (num == 1) {
System.out.println("科室修改成功\n");
} else {
System.out.println("科室修改失败,SQL语句为:" + sql + "\n");
}
//关闭数据库连接
statement.close();
conn.close();
}
删除
public void deleteKeShiByID(int id) throws ClassNotFoundException, SQLException {
//获得连接
Connection conn = DriverManager.getConnection(connStr, user, pwd);
Statement statement = conn.createStatement();
//sql
String sql = "DELETE FROM ke_shi WHERE id =" + id;
// System.out.println(sql);
int num = statement.executeUpdate(sql);
if (num == 1) {
System.out.println("科室删除成功\n");
} else {
System.out.println("科室删除失败,SQL语句为:" + sql + "\n");
}
//关闭数据库连接
statement.close();
conn.close();
}
文章来源:https://blog.csdn.net/qq_44627608/article/details/135105705
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!