java怎么添加数据到数据库

53次阅读

共计 1864 个字符，预计需要花费 5 分钟才能阅读完成。

要将数据添加到数据库中，需要完成以下步骤：

1. 导入数据库驱动程序：首先，需要下载并导入适用于您所使用的数据库的驱动程序。不同的数据库有不同的驱动程序，可以在数据库官方网站或 Maven 中央库中找到适当的驱动程序。

java


   import java.sql.*;

2. 建立数据库连接：使用驱动程序提供的连接字符串、用户名和密码来建立与数据库的连接。

java


   String url = "jdbc:mysql://localhost:3306/mydatabase";
   String username = "username";
   String password = "password";
   
   Connection connection = DriverManager.getConnection(url, username, password);

3. 创建 SQL 语句：使用 SQL 语句来定义要执行的数据库操作。例如，要向表中插入一条新记录，可以使用插入语句。

java


   String sql = "INSERT INTO mytable (column1, column2) VALUES (?, ?)";

4. 创建 PreparedStatement 对象：使用 Connection 对象的 prepareStatement()方法创建 PreparedStatement 对象。该对象允许您使用参数化查询。

java


   PreparedStatement statement = connection.prepareStatement(sql);

5. 设置参数值：使用 PreparedStatement 对象的 set 方法，将要插入的值设置为参数的值。

java


   statement.setString(1, value1);
   statement.setString(2, value2);

6. 执行 SQL 语句：使用 PreparedStatement 对象的 executeUpdate()方法执行 SQL 语句。

java


   statement.executeUpdate();

7. 关闭连接和资源：在完成数据库操作后，务必关闭连接和释放资源。

java


   statement.close();
   connection.close();

完整的示例代码如下所示：

java import java.sql.*;


public class Main {
    public static void main(String[] args) {
        try {
            // 1. 导入数据库驱动程序
            Class.forName("com.mysql.jdbc.Driver");
            // 2. 建立数据库连接
            String url = "jdbc:mysql://localhost:3306/mydatabase";
            String username = "username";
            String password = "password";
            Connection connection = DriverManager.getConnection(url, username, password);
            // 3. 创建 SQL 语句
            String sql = "INSERT INTO mytable (column1, column2) VALUES (?, ?)";
            // 4. 创建 PreparedStatement 对象
            PreparedStatement statement = connection.prepareStatement(sql);
            // 5. 设置参数值
            statement.setString(1, value1);
            statement.setString(2, value2);
            // 6. 执行 SQL 语句
            statement.executeUpdate();
            // 7. 关闭连接和资源
            statement.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }