java 多线程处理数据库

在 Java 中，可以使用多线程处理数据库操作。以下是一个简单的示例：

import java.sql.*;

public class DBThread extends Thread {
    private Connection conn;
    private String sql;

    public DBThread(Connection conn, String sql) {
        this.conn = conn;
        this.sql = sql;
    }

    public void run() {
        try {
            Statement stmt = conn.createStatement();
            stmt.executeUpdate(sql);
            stmt.close();
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) throws SQLException {
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/mydatabase", "username", "password");

        DBThread thread1 = new DBThread(conn, "INSERT INTO mytable (col1, col2) VALUES ('val1', 'val2')");
        DBThread thread2 = new DBThread(conn, "UPDATE mytable SET col1='newval' WHERE col2='val2'");

        thread1.start();
        thread2.start();

        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        conn.close();
    }
}

在这个示例中，我们创建了一个 `DBThread` 类，用于执行数据库操作。我们传入了一个 `Connection` 对象和一个 SQL 语句作为参数，然后在 `run` 方法中执行 SQL 语句。我们还创建了两个线程，每个线程都执行不同的 SQL 语句。

需要注意的是，多线程处理数据库操作时需要确保线程安全。在上面的示例中，我们创建了两个线程分别执行不同的 SQL 语句，这样可以避免多个线程同时执行同一条 SQL 语句导致的问题。另外，在使用 JDBC 连接数据库时，需要确保每个线程都拥有独立的 `Connection` 对象，以避免多个线程同时操作同一个 `Connection` 对象导致的问题。