Java连接MySql，以及Statement，PreparedStatement，ResultSet 用法和区别

怼烎@ 2022-05-09 02:10 199阅读 0赞

## 前言： ##

java开发过程中经常需要和 MySql 打交道，本文把常用的 Statement，PreparedStatement，ResultSet 的用法都梳理一遍

1.首先声明一下依赖

<dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>6.0.6</version>
            </dependency>

这个依赖用于java连接 mysql，如果不喜欢用依赖可以直接去网上下载一个mysql-connector-java的jar包放在工程目录下，没有太大差别。

2.贴一个连接代码，用于获取 MySql 的 Connection

import java.sql.*;
    import java.util.Properties;
    
    public class MySqlConnection {
        private Connection conn = null;
    
        public MySqlConnection(Properties props) {
            String driver = props.getProperty("mysql_driver");
            String url = props.getProperty("mysql_url");
            String user = props.getProperty("mysql_user");
            String pwd = props.getProperty("mysql_password");
            try {
                Class.forName(driver);
                conn = DriverManager.getConnection(url, user, pwd);
                System.out.println("mysql connect success");
            } catch (ClassNotFoundException | SQLException e) {
                e.printStackTrace();
                System.out.println("mysql connect failed");
            }
        }
    
        public Connection getConnection(){
            return conn;
        }
        
    }

在上面代码块中使用的是 property 读取的方式获得连接信息的，有助于保护连接信息

3.介绍一下 Statement，PreparedStatement，ResultSet 的用法  
个人推崇使用 PreparedStatement 代替 Statement，前者拥有后者所有功能，并且执行更快，使用更加灵活  
eg，

import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    public class InsertData {
    
        public static void insertData(Connection conn) {
            String selectSql = "select * from TestTb where name=?";
            String insertSql = "insert into TestTb (id, name, count) values(?,?,?)";
    
            boolean hasStored = false;
            try (PreparedStatement pstSelect = conn.prepareStatement(selectSql)) {
                pstSelect.setString(1, "德玛");  //给selectSql 语句的第一个问号赋值
                try (ResultSet rs = pstSelect.executeQuery()) {
                    if (rs.next()) {   //如果查询没返回，rs.next就是false；经常被用来判断数据库是否有满足需求的数据
                        hasStored = true;
                        int id = rs.getInt("id");
                        System.out.println("德玛 ID :" + id);
                    } else System.out.println("mysql has not value,need create new");
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
    
            if (!hasStored) {
                try (PreparedStatement pstInsert = conn.prepareStatement(insertSql)) {
                    pstInsert.setInt(1, 1); //给insertSql 语句的第一个问号赋值
                    pstInsert.setString(2, "德玛"); //给insertSql语句的第二个问号赋值
                    pstInsert.setInt(3, 0); //给insertSql语句的第三个问号赋值
                    pstInsert.execute();
                    System.out.println("insert new data success");
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

4.然后写一个测试类

import java.io.BufferedInputStream;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.Properties;
    
    public class MySqlConnectionTest {
        public static void main(String[] args) {
            Properties props = new Properties();
            try (InputStream in = new BufferedInputStream(new FileInputStream("src/test/resources/build.property"))) {  //property文件在工程的目录下
                props.load(in);
            } catch (IOException e) {
                e.printStackTrace();
            }
            MySqlConnection mysqlConnector = new MySqlConnection(props);  //创建连接类
            Connection conn = mysqlConnector.getConnection(); //获取 Connection 连接
            InsertData.insertData(conn); //执行插入操作
            
            try {
                conn.close(); //关闭连接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

另外property文件的结构展示如下

mysql_driver = com.mysql.jdbc.Driver
    mysql_url = jdbc:mysql://ip地址:端口号/数据库名?useUnicode=true&characterEncoding=UTF-8
    mysql_user = user
    mysql_password = password

5.输出结果  
数据库涉及个人信息，不做展示。

6.结语  
与君共勉，祝君进步