java操作数据库操作类

时间:2020-01-08 11:07:42 类型:JAVA
字号:    

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下载


Db.zip


<