模板：JDBC 连接数据库并实现 CRUD

目录

前期准备：

1. 连接数据库

1.1 第一种

 1.2 第二种

2. 增加

3. 修改

4. 删除

5. 查询

5.1 查询某个记录

5.2 查询单列数据

使用时，直接复制再修改一些数据即可；

声明：在对文件/变量命名时，没有做到见名知意，后续会对代码改进，实在抱歉（不会被打死吧！）；

前期准备：

参考详细演示部分：CSDNhttps://mp.csdn.net/mp_blog/creation/editor/140002021

1. 连接数据库

1.1 第一种

import java.sql.*;public class JdbcTest {//记得类名与文件名保持一致//1.加载jdbc连接mysql的驱动public final static String driver="com.mysql.cj.jdbc.Driver";//2.连接MySQL数据库的地址public final static String url="jdbc:mysql://localhost:3306/shangguigu";//shangguigu为数据库名称//3.连接MySQL的用户名public final static String user="root";//4.连接MySQL的密码public final static String pwd="xxxxx";//输入自己数据库的密码//static 静态代码加载 jdbc 的驱动static {try{Class.forName(driver);} catch (ClassNotFoundException e) {throw new RuntimeException(e);}}//连接MySQL的连接对象public static Connection getConn(){try{return DriverManager.getConnection(url,user,pwd);} catch (SQLException e){e.printStackTrace();}return null;}//关闭连接，保证MySQL资源的释放，能够充分利用资源public static void close(ResultSet rs, PreparedStatement ps,Connection conn){try{if (rs != null){rs.close();}if (ps != null){ps.close();}if (conn != null){conn.close();}} catch (SQLException e) {throw new RuntimeException(e);}}//验证public static void main(String[] args) {System.out.println(getConn());}
}

 结果为一个地址，则连接成功；

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=14436:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" JdbcTest
com.mysql.cj.jdbc.ConnectionImpl@3023df74进程已结束,退出代码0

 1.2 第二种

一般来说第一种较好；

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;public class JavaCon {public static void main(String[] args) throws Exception {//注册驱动Class.forName("com.mysql.cj.jdbc.Driver");//获取连接对象String url="jdbc:mysql://localhost:3306/shangguigu";//3306/ 后面是连接的数据库的名字String username="root";String password="xxxxxx";// 填入自己数据库的密码Connection connection= DriverManager.getConnection(url,username,password);//获取执行SQL语句的对象Statement statement=connection.createStatement();//编写Sql语句,执行并返回结果集String sql=" select emp_id,emp_name,emp_salary,emp_age from t_emp";// 输入要查询的字段ResultSet resultSet=statement.executeQuery(sql);//处理结果，遍历 resultSet 结果集while (resultSet.next()){  //根据字段的名字和数据类型进行修改int id=resultSet.getInt("emp_id");String na=resultSet.getString("emp_name");String salary=resultSet.getString("emp_salary");int age=resultSet.getInt("emp_age");System.out.println(id+"\t"+na+"\t"+salary+"\t"+age);}//释放资源(先开后关)resultSet.close();statement.close();connection.close();}
}

结果为查询表格的内容，则连接成功：

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=3911:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc-test9\out\production\jdbc-test9;C:\Test\java _test\jdbc-test9\lib\mysql-connector-java-8.0.26.jar" JDBC.JavaCon
1	王	8.1	6
2	李	9.3	1
3	张	7.5	2进程已结束,退出代码0

public class CRUD {//为方便接下来能够看懂，注意类名为 CRUD//一表一类private int emp_id;private String emp_name;private double emp_salary;private String emp_age;public int getEmp_id() {return emp_id;}public void setEmp_id(int emp_id) {this.emp_id = emp_id;}public String getEmp_name() {return emp_name;}public void setEmp_name(String emp_name) {this.emp_name = emp_name;}public double getEmp_salary() {return emp_salary;}public void setEmp_salary(double emp_salary) {this.emp_salary = emp_salary;}public String getEmp_age() {return emp_age;}public void setEmp_age(String emp_age) {this.emp_age = emp_age;}
}

2. 增加

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class CrudOperation {//为方便接下来能够看懂，注意类名//新增数据到数据库中，public boolean add(CRUD crud){//执行增删改查的SQL语句//连接MySQLConnection connection=JdbcTest.getConn();//预编译SQl执行String sql="insert into t_emp values (?,?,?,?)";//？相当于占位符，四个字段四个占位符try {PreparedStatement ps= connection.prepareStatement(sql);//根据要操作的表修改ps.setInt(1,crud.getEmp_id());ps.setString(2,crud.getEmp_name());ps.setDouble(3,crud.getEmp_salary());ps.setString(4,crud.getEmp_age());//执行操作更改boolean result=ps.executeUpdate()>0;//关闭数据库JdbcTest.close(null,ps,connection);return result;} catch (SQLException e) {throw new RuntimeException(e);}// return false;}public static void main(String[] args) {CRUD cr = new CRUD();cr.setEmp_id(10);//根据要操作的表修改cr.setEmp_name("熊大");cr.setEmp_salary(70.8);cr.setEmp_age("7");CrudOperation cp = new CrudOperation();if(cp.add(cr)){System.out.println("保存学生成功");}else {System.out.println("保存学生失败");}}
}

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=4536:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" CrudOperation
保存学生成功进程已结束,退出代码0

 再检查一下：

3. 修改

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class Operation_Update {public boolean update(CRUD crud) {//执行增删改查的SQL语句//连接MySQLConnection connection = JdbcTest.getConn();//预编译SQl执行String sql = "update t_emp set emp_name=?,emp_salary=?,emp_age=? where emp_id=?";//？相当于占位符，四个字段四个占位符try {PreparedStatement ps = connection.prepareStatement(sql);//根据要操作的表修改//ps.setInt(1, crud.getEmp_id());ps.setString(1, crud.getEmp_name());ps.setDouble(2, crud.getEmp_salary());ps.setString(3, crud.getEmp_age());//多加一个修改的emp_idps.setInt(4, crud.getEmp_id());//执行操作更改boolean result = ps.executeUpdate() > 0;JdbcTest.close(null, ps, connection);return result;} catch (SQLException e) {throw new RuntimeException(e);}}public static void main(String[] args) {//修改学生信息CRUD cr1 = new CRUD();cr1.setEmp_id(10);//根据要操作的表修改cr1.setEmp_name("熊二");cr1.setEmp_salary(90.8);cr1.setEmp_age("9");Operation_add cp1 = new Operation_add();if(cp1.update(cr1)){System.out.println("修改学生成功");}else{System.out.println("修改学生失败");}}
}

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=7593:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" Operation_Update
修改学生成功进程已结束,退出代码0

4. 删除

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;public class Operation_Delete {public boolean delete(int emp_id) {//执行增删改查的SQL语句//连接MySQLConnection connection = JdbcTest.getConn();//预编译SQl执行String sql = "delete from t_emp where emp_id=?";//？相当于占位符try {PreparedStatement ps = connection.prepareStatement(sql);ps.setInt(1,emp_id);//根据要操作的表修改//执行操作更改boolean result = ps.executeUpdate() > 0;//关闭数据库JdbcTest.close(null, ps, connection);return result;} catch (SQLException e) {throw new RuntimeException(e);}}//修改学生信息public static void main(String[] args) {Operation_Delete de=new Operation_Delete();if(de.delete(10)){System.out.println("删除学生成功");}else {System.out.println("删除学生失败");}}
}

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=10541:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" Operation_Delete
删除学生成功进程已结束,退出代码0

5. 查询

5.1 查询某个记录

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class Operation_Query {public CRUD query(int emp_id) {//主键或其他字段//执行增删改查的SQL语句//连接MySQLConnection connection = JdbcTest.getConn();//预编译SQl执行String sql = "select * from t_emp where emp_id=?";//？相当于占位符try {PreparedStatement ps = connection.prepareStatement(sql);ps.setInt(1, emp_id);//根据要操作的表修改//执行操作更改ResultSet rs = ps.executeQuery();//创建对象，返回CRUD cr = new CRUD();while (rs.next()) {cr.setEmp_id(rs.getInt(1));cr.setEmp_name(rs.getString(2));cr.setEmp_salary(rs.getDouble(3));cr.setEmp_age(rs.getString(4));}//关闭数据库JdbcTest.close(rs, ps, connection);return cr;} catch (SQLException e) {e.printStackTrace();}return  null;}public static void main(String[] args) {Operation_Query oq=new Operation_Query();CRUD cr2=oq.query(1);System.out.println(cr2.getEmp_id()+"\t"+cr2.getEmp_salary()+"\t"+cr2.getEmp_name()+"\t"+cr2.getEmp_age());}
}

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=1330:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" Operation_Query
1	8.1	王	6进程已结束,退出代码0

5.2 查询单列数据

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;public class Operation_Query_List {public List<CRUD> ger_all() {//主键或其他字段//执行增删改查的SQL语句//连接MySQLConnection connection = JdbcTest.getConn();//预编译SQl执行String sql = "select * from t_emp ";//？相当于占位符try {PreparedStatement ps = connection.prepareStatement(sql);//执行操作更改ResultSet rs = ps.executeQuery();//创建对象，返回List<CRUD> list = new ArrayList<CRUD>();while (rs.next()) {CRUD cr = new CRUD();cr.setEmp_id(rs.getInt(1));cr.setEmp_name(rs.getString(2));cr.setEmp_salary(rs.getDouble(3));cr.setEmp_age(rs.getString(4));
//                    当前对象存储到 list 集合中list.add(cr);}//关闭数据库JdbcTest.close(rs, ps, connection);return list;} catch (SQLException e) {e.printStackTrace();}return  null;}public static void main(String[] args) {Operation_Query_List ql=new Operation_Query_List();List<CRUD> list = ql.ger_all();for (CRUD cr : list){System.out.println(cr.getEmp_id()+"=》"+ cr.getEmp_name());}}
}

C:\Java\jdk-17.0.11\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\lib\idea_rt.jar=5193:C:\Program Files\JetBrains\IntelliJ IDEA 2022.1.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Test\java _test\jdbc_test0917\out\production\jdbc_test0917;C:\Test\java _test\jdbc_test0917\lib\mysql-connector-java-8.0.26.jar" Operation_Query_List
1=》王
2=》李
3=》张进程已结束,退出代码0