java多线程执行sql

可以使用Java的JDBC API来执行SQL语句，同时使用多线程来提高执行效率。具体实现如下：

1. 创建一个数据库连接池，可以使用开源的连接池框架如C3P0、Druid等。

2. 创建一个线程池，使用Java的ExecutorService实现。

3. 在每个线程中获取一个数据库连接，使用Connection对象创建一个Statement对象。

4. 执行SQL语句，使用Statement对象的execute()或executeUpdate()方法。

5. 关闭Statement对象和数据库连接。

6. 在每个线程执行完毕后，关闭线程池。

下面是一个简单的示例代码：

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import javax.sql.DataSource;

public class MultiThreadedSqlExecutor {

    private final DataSource dataSource;

    public MultiThreadedSqlExecutor(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public void executeSqlInParallel(String[] sqlStatements) {
        ExecutorService executor = Executors.newFixedThreadPool(sqlStatements.length);

        for (String sql : sqlStatements) {
            executor.execute(new SqlTask(sql));
        }

        executor.shutdown();
    }

    private class SqlTask implements Runnable {

        private final String sql;

        public SqlTask(String sql) {
            this.sql = sql;
        }

        @Override
        public void run() {
            Connection conn = null;
            Statement stmt = null;
            try {
                conn = dataSource.getConnection();
                stmt = conn.createStatement();
                stmt.executeUpdate(sql);
            } catch (SQLException e) {
                e.printStackTrace();
            } finally {
                try {
                    if (stmt != null) {
                        stmt.close();
                    }
                    if (conn != null) {
                        conn.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

在上面的代码中，使用了Java的ExecutorService来创建一个线程池，然后在每个线程中使用DataSource对象获取数据库连接，执行SQL语句并关闭连接。通过调用executeSqlInParallel()方法来启动多个线程执行SQL语句。