JDBC和多线程

广州旋转

我正在尝试使用多线程方法运行一些查询，但是我认为我做错了，因为我的程序大约需要五分钟才能运行一个简单的select语句，例如
SELECT * FROM TABLE WHERE ID = 123'
我的实现如下，并且我正在使用一个连接对象。
在我的运行方法中
public void run() {
runQuery(conn, query);
}
runQuery方法
public void runQuery(Connection conn, String queryString){
Statement statement;
try {
      statement = conn.createStatement();
      ResultSet rs = statement.executeQuery(queryString);
      while (rs.next()) {}
} catch (SQLException e) {
      e.printStackTrace();
}
}
最后，在main方法中，我使用下面的代码片段启动线程。
MyThread bmthread = new MyThread(conn, query);
ArrayList allThreads = new ArrayList();
double start = System.currentTimeMillis();
int numberOfThreads = 1;
for(int i=0; i更新：我现在为每个线程使用单独的连接。
ArrayList sqlConn = new ArrayList();
for(int i =0; i如rohivats和Asaph所说，一个连接必须由一个线程使用，并且只有一个线程，即考虑使用数据库连接池。考虑到c3p0，DBCP和类似的东西几乎被遗弃了，我将使用HikariCP，它确实是快速而可靠的。
如果您想要非常简单的内容，则可以使用线程安全集合（例如LinkedList）来实现一个非常简单的连接池，例如：
public class CutrePool{
   String connString;
   String user;
   String pwd;
   static final int INITIAL_CAPACITY = 50;
   LinkedList pool = new LinkedList();
   public String getConnString() {
      return connString;
   }
   public String getPwd() {
      return pwd;
   }
   public String getUser() {
      return user;
   }
   public CutrePool(String connString, String user, String pwd) throws SQLException {
      this.connString = connString;
      for (int i = 0; i 如您所见，getConnection和returnConnection方法被同步为线程安全的。获得连接（conn =
pool.getConnection();），不要忘了在使用后返回/释放连接（pool.returnConnection(conn);）

JDBC和多线程

广州旋转 LV1