Java连接mysql数据库代码实例程序

这里提供的完整攻略将帮助大家编写Java连接mysql数据库的代码实例程序。

步骤一：下载并安装JDBC驱动程序

在使用Java连接mysql数据库之前，我们需要下载并安装mysql JDBC驱动程序。这里我们以mysql-connector-java-8.0.25.jar为例，在这个网页上下载mysql JDBC驱动程序：https://dev.mysql.com/downloads/connector/j/8.0.html

下载完成后，将mysql-connector-java-8.0.25.jar文件引入到项目中的"lib"文件夹下。

步骤二：编写Java代码连接mysql数据库

import java.sql.*;

public class JavaMysqlDemo {
    static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver"; //mysql驱动
    static final String DB_URL = "jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai";
    static final String USER = "root"; //mysql用户名
    static final String PASS = "password"; //mysql密码
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            Class.forName(JDBC_DRIVER);
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            System.out.println("连接成功！");

            stmt = conn.createStatement();
            String sql = "SELECT * FROM user_info";
            ResultSet rs = stmt.executeQuery(sql);

            while(rs.next()){
               int id  = rs.getInt("id");
               String name = rs.getString("name");
               String email = rs.getString("email");
               String password = rs.getString("password");
               String country = rs.getString("country");
               System.out.println("ID:"+id+", 姓名："+name+", Email："+email+", 密码："+password+", 国家："+country);
            }
            rs.close();
            stmt.close();
            conn.close();
        } catch(SQLException se) {
            se.printStackTrace();
        } catch(Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if(stmt!=null) stmt.close();
            } catch(SQLException se2) {
            }
            try {
                if(conn!=null) conn.close();
            } catch(SQLException se) {
                se.printStackTrace();
            }
        }
    }
}

在第6行中，我们定义了mysql驱动的名称，而在第7行定义了要连接的数据库的URL。在第8行和第9行中，我们设置了要连接的mysql用户名和密码。

在代码的第14行，我们尝试通过调用DriverManager类的getConnection()方法来建立与mysql数据库的连接。getConnection()方法接收三个参数，分别是要连接的数据库的URL、用户名和密码。

在代码的第17行，我们创建了一个Statement对象来执行SQL查询。通过调用Statement类的executeQuery()方法来执行SQL查询语句的语句，并将返回结果存储到ResultSet对象中。

在代码的第21-26行，我们使用while循环来遍历ResultSet对象中的每一项。在这里，我们只是简单地输出每个用户的ID、姓名、电子邮件、密码和国家的名称。

在代码的最后一个catch块中，我们关闭了ResultSet对象、Statement对象和Connection对象以及任何从这些对象分配的资源。

步骤三：运行Java程序

编译和运行Java代码的过程与一般的Java程序相同。从命令行中键入“javac JavaMysqlDemo.java”来编译Java代码，再键入“java JavaMysqlDemo”来运行Java代码。

示例：

import java.sql.*;

public class JavaMysqlDemo2 {
    static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver"; //mysql驱动
    static final String DB_URL = "jdbc:mysql://localhost:3306/test_db?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai";
    static final String USER = "root"; //mysql用户名
    static final String PASS = "password"; //mysql密码
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            Class.forName(JDBC_DRIVER);
            conn = DriverManager.getConnection(DB_URL, USER, PASS);
            System.out.println("连接成功！");

            //插入一条新的数据
            stmt = conn.createStatement();
            String sql = "INSERT INTO user_info(id, name, email, password, country) VALUES (5, 'Tom', '[e-mail]', '123456', 'USA')";
            stmt.executeUpdate(sql);

            //查询所有数据
            sql = "SELECT * FROM user_info";
            ResultSet rs = stmt.executeQuery(sql);

            while(rs.next()){
               int id  = rs.getInt("id");
               String name = rs.getString("name");
               String email = rs.getString("email");
               String password = rs.getString("password");
               String country = rs.getString("country");
               System.out.println("ID:"+id+", 姓名："+name+", Email："+email+", 密码："+password+", 国家："+country);
            }
            rs.close();
            stmt.close();
            conn.close();
        } catch(SQLException se) {
            se.printStackTrace();
        } catch(Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if(stmt!=null) stmt.close();
            } catch(SQLException se2) {
            }
            try {
                if(conn!=null) conn.close();
            } catch(SQLException se) {
                se.printStackTrace();
            }
        }
    }
}

在这个示例中，我们向之前的用户表中插入了一条新的数据，并输出了所有的数据。