JDBC使用

46次阅读

共计 2574 个字符，预计需要花费 7 分钟才能阅读完成。

JDBC 资源包
链接：https://pan.baidu.com/s/1JaZ3…
提取码：858d

Class.forName()加载数据库连接驱动。
DriverManager.getConnection()获取数据连接对象。
根据 SQL 语句获取会话对象，会话对象一般用 PreparedStatement 类型
执行 SQL 处理结果集
关闭结果集、关闭会话、关闭连接

封装函数

public class SqlUtils {
    private static String driver = "com.mysql.jdbc.Driver";
    private static String url = "";
    private static String username = "";
    private static String password = "";

    static {
        // 加载驱动
        try {Class.forName(driver);
        } catch (ClassNotFoundException e) {e.printStackTrace();
        }
    }

    // 只产生一个连接
    public static Connection getConnection() throws SQLException {System.out.println("连接数据库...");
        return DriverManager.getConnection(url, username, password);
    }

    public static void release(Connection connection, Statement statement, ResultSet resultSet) {if (resultSet != null) {
            try {resultSet.close();
            } catch (SQLException e) {e.printStackTrace();
            }
        }
        if (statement != null) {
            try {statement.close();
            } catch (SQLException e) {e.printStackTrace();
            }
        }
        if (connection != null) {
            try {connection.close();
            } catch (SQLException e) {e.printStackTrace();
            }
        }
    }
}

测试用例

public class test {public static void main(String[] args) throws SQLException {
        // 加载驱动，创建连接
        Connection connection = SqlUtils.getConnection();
        //SQL 语句
        String insert = "INSERT INTO `user` (id,username,password) VALUE (?,?,?);";
        String select = "SELECT * FROM `user`;";
        // 将事务设置为手动提交
        connection.setAutoCommit(false);
        PreparedStatement statement1;
        PreparedStatement statement2;
        try{
            // 根据 sql 语句，得到预编译语句对象
            statement1 = connection.prepareStatement(insert);
            statement2 = connection.prepareStatement(select);

            for(int i=1;i<=10;i++){
                // 按占位符设置参数值
                statement1.setInt(1,i);
                statement1.setString(2,"user_"+i);
                statement1.setString(3,"password"+i);
                // 放入批处理队列
                statement1.addBatch();}
            // 执行插入语句，批量插入，事务
            statement1.executeBatch();

            // 执行查询语句，得到结果集
            ResultSet result = statement2.executeQuery();
            // 遍历、打印结果
            while (result.next()){System.out.println("username:"+result.getObject("username")+";password:"+result.getObject("password"));
            }
            // 提交事务
            connection.commit();

            // 关闭连接，释放资源
            SqlUtils.release(connection,statement1,result);
            SqlUtils.release(connection,statement2,result);

        }catch (Exception e){e.printStackTrace();
        }
    }
}

PreparedStatement 继承 Statement，PreparedStatement 包含已编译的 SQL 语句，其执行速度比 Statement 要快。Statement 会频繁编译 SQL。PreparedStatement 可对 SQL 进行预编译，提高效率，预编译的 SQL 存储在 PreparedStatement 对象中。
在 JDBC 中，任何时候都不要用 Statement，因为：

代码的可读性和维护性，Statement 需要不断的拼接
PreparedStatement 性能更好，有缓存机制
PreparedStatement 安全性更加高，Statement 容易被 sql 注入，通过分隔符 ’++’, 编写永等式，可以不需要密码就进入数据库，PreparedStatement 传入的内容不会和 sql 语句发生任何匹配关系

准备：建立一个数据库缓冲池