当前位置:首页 > 行业动态 > 正文

java连接mysql的代码

以下是一段Java连接MySQL数据库的示例代码:,,“ java,import java.sql.*;,,public class MySQLConnection {, public static void main(String[] args) {, // JDBC驱动名和数据库URL, String jdbcDriver = "com.mysql.jdbc.Driver";, String dbUrl = "jdbc:mysql://localhost/mydatabase";,, // 数据库用户名和密码, String username = "your_username";, String password = "your_password";,, try {, // 注册JDBC驱动程序, Class.forName(jdbcDriver);,, // 打开数据库连接, Connection conn = DriverManager.getConnection(dbUrl, username, password);,, // 执行查询操作, Statement stmt = conn.createStatement();, ResultSet rs = stmt.executeQuery("SELECT * FROM your_table");,, // 处理结果集, while (rs.next()) {, // 获取数据并输出, int id = rs.getInt("id");, String name = rs.getString("name");, System.out.println("ID: " + id + ", Name: " + name);, },, // 关闭连接, rs.close();, stmt.close();, conn.close();, } catch (Exception e) {, e.printStackTrace();, }, },},“,,请注意,上述代码中的”mydatabase”、”your_username”、”your_password”和”your_table”需要替换为实际的数据库名称、用户名、密码和表名。还需要确保已将MySQL的JDBC驱动程序添加到项目的类路径中。

导入相关依赖

在Java项目中,我们需要导入MySQL的JDBC驱动包,以便能够连接MySQL数据库,可以在项目的pom.xml文件中添加以下依赖:

java连接mysql的代码  第1张

<dependencies>
    <!MySQL Connector Java >
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysqlconnectorjava</artifactId>
        <version>8.0.26</version>
    </dependency>
</dependencies>

编写数据库连接工具类

创建一个名为DBUtil的工具类,用于封装数据库连接的相关操作。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DBUtil {
    private static final String URL = "jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTC";
    private static final String USER = "your_username";
    private static final String PASSWORD = "your_password";
    static {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public static Connection getConnection() {
        Connection connection = null;
        try {
            connection = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }
}

请将your_database_name、your_username和your_password替换为实际的数据库名称、用户名和密码。

使用数据库连接工具类进行数据库操作

现在我们可以在其他类中使用DBUtil工具类来获取数据库连接,并进行相应的数据库操作,创建一个名为UserDao的类,用于操作用户表。

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
public class UserDao {
    // 查询所有用户信息
    public List<User> findAllUsers() {
        List<User> userList = new ArrayList<>();
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            connection = DBUtil.getConnection();
            String sql = "SELECT * FROM user";
            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery();
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                int age = resultSet.getInt("age");
                User user = new User(id, name, age);
                userList.add(user);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            close(resultSet, preparedStatement, connection);
        }
        return userList;
    }
    // 关闭资源的方法,用于释放数据库连接、预编译语句和结果集等资源
    private void close(AutoCloseable... closeables) {
        for (AutoCloseable closeable : closeables) {
            if (closeable != null) {
                try {
                    closeable.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

在这个例子中,我们首先通过DBUtil工具类获取到数据库连接,然后使用PreparedStatement执行SQL查询语句,最后将查询结果封装成User对象并添加到列表中,在操作完成后,需要调用close方法关闭资源。

0