用mysql-connector-java操作数据库(JDBC)_mysql-connector-java maven response

1、添加maven依赖

        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.29</version>
        </dependency>

2、单处理：更新、删除、插入

    public int singleOperate(String sql, Map<Integer, String> map) throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection conn = DriverManager.getConnection(sql_host, sql_user, sql_password);
        PreparedStatement ps = conn.prepareStatement(sql);
        for (Map.Entry<Integer, String> entry : map.entrySet()) {
            ps.setString(entry.getKey(), entry.getValue());
        }
        int i = ps.executeUpdate();
        ps.close();
        conn.close();
        return i;
    }

3、批处理：更新、删除、插入

    public String batchOperate(String sql, List<Map<Integer, String>> list) throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection conn = DriverManager.getConnection(sql_host, sql_user, sql_password);
        PreparedStatement ps = conn.prepareStatement(sql);
        for (Map<Integer, String> map : list) {
            for (Map.Entry<Integer, String> entry : map.entrySet()) {
                ps.setString(entry.getKey(), entry.getValue());
            }
            ps.addBatch();//添加到同一个批处理中
        }
        String str_re = Arrays.toString(ps.executeBatch());
        ps.close();
        conn.close();
        return str_re;
    }

4、查询

    public ResultSet query(String sql) throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.cj.jdbc.Driver");
        Connection conn = DriverManager.getConnection(sql_host, sql_user, sql_password);
        Statement stmt = conn.createStatement();
        return stmt.executeQuery(sql);
    }