java操作数据库， 如果不进行整合， 添加，删除，修改，查询等操作将会有太多的重复代码出现， 操作不易， 同时也影响美观， 因此，将重复的代码进行整合，形成一个类， 然后调用就会简单很多
package yteng;
//先在lib下引入包mysql-connector-java-5.1.39-bin.jar
import java.sql.*;
public class Db {
// MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL
static final String DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/stu_info";
// MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL
//static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
//static final String DB_URL = "jdbc:mysql://localhost:3306/stu_info?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";
static final String USER = "root";
static final String PASS = "root";
public static Connection conn = null;
public static PreparedStatement ps = null;
public static ResultSet rs = null;
static {
try {
//加载驱动
Class.forName(DRIVER); //将mysql驱动注册到DriverManager中去
//Class.forName 方法的作用，就是初始化给定的类
} catch(ClassNotFoundException e) {
System.out.println(e.getMessage());
}
}
//得到数据库连接对象
public static Connection conn() {
if(conn == null){
//获取连接
try {
conn = DriverManager.getConnection(DB_URL,USER,PASS);
} catch (SQLException e) {
e.printStackTrace();
}
//返回一个数据库连接对象, 通过个对象就可以对数据库进行增删除改查操作了
}
return conn;
}
//基本的增,删,改操作
public static int exec(String sql, Object...args) {
conn = conn();
int count = 0;
try {
//prepareStatement对象防止sql注入的方式是把用户非法输入的单引号用\反斜杠做了转义，从而达到了防止sql注入的目的
ps = conn.prepareStatement(sql);
//设置占位符参数
if(args != null) {
for(int i = 0; i < args.length; i++) {
ps.setObject(i+1, args[i]);
}
}
count = ps.executeUpdate();
//设置占位符参数
}
catch(SQLException e) {
System.out.println(e.getMessage());
}
return count;
}
//返回新增加数据的id
public static int lastInsertId(String sql, Object...args) {
conn = conn();
int id = -1;
try {
//prepareStatement对象防止sql注入的方式是把用户非法输入的单引号用\反斜杠做了转义，从而达到了防止sql注入的目的
ps = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
//设置占位符参数
if(args != null) {
for(int i = 0; i < args.length; i++) {
ps.setObject(i+1, args[i]);
}
}
ps.executeUpdate();
rs = ps.getGeneratedKeys();
if(rs.next())
{
id = rs.getInt(1);
}
//设置占位符参数
}
catch(SQLException e) {
System.out.println(e.getMessage());
}
return id;
}
//查询操作
public static ResultSet fetch(String sql, Object...args) {
conn = conn();
try {
ps = conn.prepareStatement(sql);
//设置占位符参数
if(args != null) {
for(int i = 0; i < args.length; i++) {
ps.setObject(i+1, args[i]);
}
}
rs = ps.executeQuery(); //返回 查询的数据结果
//设置占位符参数
}
catch(SQLException e) {
System.out.println(e.getMessage());
}
return rs;
}
public static void close() {
try {
if(rs != null) {rs.close(); rs = null;}
if(ps != null) {ps.close(); ps = null;}
if(conn != null) {conn.close(); conn = null;}
}
catch(SQLException e) {
System.out.println(e.getMessage());
}
}
}Db.java下载
