java 连接mysql

要使用Java连接MySQL，首先需要导入JDBC驱动，然后通过DriverManager获取数据库连接，最后执行SQL语句。

工具类简介

Java连接MySQL的工具类是一个用于简化Java程序与MySQL数据库之间连接和操作的类，通过使用这个工具类，我们可以方便地实现对数据库的增删改查等操作。

工具类功能

1、建立数据库连接

2、关闭数据库连接

3、执行SQL语句

4、处理查询结果集

5、处理更新结果

6、处理异常

工具类代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DBUtil {
    private static final String DRIVER = "com.mysql.jdbc.Driver";
    private static final String URL = "jdbc:mysql://localhost:3306/test";
    private static final String USERNAME = "root";
    private static final String PASSWORD = "123456";
    static {
        try {
            Class.forName(DRIVER);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    /**
     * 获取数据库连接
     * @return Connection对象
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USERNAME, PASSWORD);
    }
    /**
     * 关闭数据库连接
     * @param conn Connection对象
     * @param stmt Statement对象
     * @param rs ResultSet对象
     */
    public static void close(Connection conn, Statement stmt, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                rs = null;
            }
        }
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                stmt = null;
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                conn = null;
            }
        }
    }
}

使用示例

public class Main {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 获取数据库连接
            conn = DBUtil.getConnection();
            // 创建Statement对象，用于执行SQL语句
            stmt = conn.createStatement();
            // 执行查询语句，获取结果集
            rs = stmt.executeQuery("SELECT * FROM user");
            // 处理查询结果集，这里只是简单地打印出来，实际应用中可以根据需求进行处理
            while (rs.next()) {
                System.out.println("id: " + rs.getInt("id") + ", name: " + rs.getString("name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭数据库连接，释放资源
            DBUtil.close(conn, stmt, rs);
        }
    }
}