java和mysql连接

Java和MySQL可以通过JDBC(Java Database Connectivity)进行连接,首先需要导入MySQL的JDBC驱动包,然后使用DriverManager获取数据库连接。

在Java中连接MySQL数据库,我们需要一个配置文件来存储数据库的连接信息,以下是一个详细的步骤和示例:

1、创建MySQL配置文件(dbconfig.properties)

java和mysql连接

在项目的资源文件夹(如:src/main/resources)中创建一个名为dbconfig.properties的文件,用于存储数据库连接信息,文件内容如下:

数据库连接配置
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTC
jdbc.username=your_username
jdbc.password=your_password

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

2、读取配置文件中的数据库连接信息

java和mysql连接

在Java代码中,我们使用java.util.Properties类来读取配置文件中的数据库连接信息,需要导入相关包:

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

创建一个方法来读取配置文件并获取数据库连接信息:

public static Connection getConnection() {
    Properties properties = new Properties();
    InputStream inputStream = null;
    Connection connection = null;
    try {
        inputStream = ClassLoader.getSystemResourceAsStream("dbconfig.properties");
        properties.load(inputStream);
        String driver = properties.getProperty("jdbc.driver");
        String url = properties.getProperty("jdbc.url");
        String username = properties.getProperty("jdbc.username");
        String password = properties.getProperty("jdbc.password");
        Class.forName(driver);
        connection = DriverManager.getConnection(url, username, password);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        if (inputStream != null) {
            try {
                inputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    return connection;
}

3、使用数据库连接信息进行操作

java和mysql连接

现在,我们可以使用getConnection()方法获取到的数据库连接信息进行各种操作,例如查询、插入、更新等,以下是一个简单的查询示例:

public static void main(String[] args) {
    Connection connection = getConnection();
    if (connection != null) {
        try {
            String sql = "SELECT * FROM your_table_name";
            java.sql.Statement statement = connection.createStatement();
            java.sql.ResultSet resultSet = statement.executeQuery(sql);
            while (resultSet.next()) {
                // 处理查询结果,例如打印到控制台或输出到文件等
                System.out.println(resultSet.getString("column_name"));
            }
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    } else {
        System.out.println("无法获取数据库连接");
    }
}

请将your_table_namecolumn_name替换为实际的表名和列名。

原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/640786.html

(0)
未希的头像未希新媒体运营
上一篇 2024-05-21 08:51
下一篇 2024-05-21 08:52

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注

云产品限时秒杀。精选云产品高防服务器,20M大带宽限量抢购  >>点击进入