基于java線程池讀取單個SQL數據庫表
更新時間：2019年08月29日 16:18:42 作者：Cedric是陳大澤
這篇文章主要為大家詳細介紹了基于java線程池讀取單個SQL數據庫表，具有一定的參考價值，感興趣的小伙伴們可以參考一下
任務：基于線程池來操作MySQL，測試單臺機器讀寫MySQL單表的效率。
思路：創(chuàng)建一個大小合適的線程池，讓每個線程分別連接到數據庫并進行讀取輸出操作。
連接到數據庫
import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Statement;
public class TEXT {
}
class MySQLOpen {
private Connection con = null;
private static String driver = "com.mysql.jdbc.Driver";
private static String url = "jdbc:mysql://localhost:3306/phpmyadmin";
private static String username = "root";
private static String password = "root";
private static Statement NULL = null;
public void MysqlOpen() {
try {
Class.forName(driver); //加載驅動類
con = DriverManager.getConnection(url, username, password); //連接數據庫
if (!con.isClosed())
System.out.println("***數據庫成功連接***");
} catch (ClassNotFoundException e) {
System.out.println("找不到驅動程序類，加載驅動失敗");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("數據庫連接失敗");
e.printStackTrace();
}
}
}
利用statement類中的executeQuery方法操作MySQL
Statement state = (Statement) con.createStatement();
ResultSet sql = state.executeQuery("select * from user where id between 1 and 5");
利用sql.next()循環(huán)遍歷取出想要的數據
while (sql.next()) {
String id = sql.getString(1);
String username = sql.getString(3);
String text = sql.getString(6);
System.out.println(id+"\t"+username+"\t"+text);
}
以上就已經實現(xiàn)了主線程訪問并操作數據庫的相應內容。
創(chuàng)建線程池，設置好相應參數
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 15, 200, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(5));
利用for循環(huán)去創(chuàng)建線程即可。
計算效率
long start = System.currentTimeMillis();
long end = System.currentTimeMillis();
System.out.println("平均每秒可輸出: " + 100000 / (end - start) + " 條");
要注意主線程創(chuàng)建好其他線程后就繼續(xù)往下執(zhí)行了，所以要有一個判斷其他線程是否結束的語句
while (true) {
if (executor.getActiveCount() == 0)
break;
}
可以利用Thread.activeCount()看一還有多少 活躍的線程。
System.out.println("activeCountMain1 : " + Thread.activeCount());
主要的思路就再上面，現(xiàn)在貼出整理好的代碼：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import com.mysql.jdbc.Statement;
public class Main {
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 15, 200, TimeUnit.MILLISECONDS,
new ArrayBlockingQueue<Runnable>(5));
long start = System.currentTimeMillis();
System.out.println("activeCountMain1 : " + Thread.activeCount());
for (int i = 1; i <= 20; i++) {
MySQL mysql = new MySQL(i);
executor.execute(mysql);
System.out.println("線程池中線程數目：" + executor.getPoolSize() + "，隊列中等待執(zhí)行的任務數目：" + executor.getQueue().size()
+ "，已執(zhí)行玩別的任務數目：" + executor.getCompletedTaskCount());
}
executor.shutdown();
while (true) {
if (executor.getActiveCount() == 0)
break;
}
System.out.println("activeCountMain2 : " + Thread.activeCount());
long end = System.currentTimeMillis();
System.out.println("平均每秒可輸出: " + 100000 / (end - start) + " 條");
}
}
class MySQL implements Runnable {
private Connection con = null;
private static String driver = "com.mysql.jdbc.Driver";
private static String url = "jdbc:mysql://localhost:3306/phpmyadmin";
private static String username = "root";
private static String password = "root";
private static Statement NULL = null;
private final int taskNum;
public MySQL(int taskNum) {
this.taskNum = taskNum;
}
public Statement MysqlOpen() {
try {
Class.forName(driver); //加載驅動類
con = DriverManager.getConnection(url, username, password); //連接數據庫
if (!con.isClosed())
System.out.println("***數據庫成功連接***");
Statement state = (Statement) con.createStatement();
return state;
} catch (ClassNotFoundException e) {
System.out.println("找不到驅動程序類，加載驅動失敗");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("數據庫連接失敗");
e.printStackTrace();
}
return NULL;
}
@Override
public void run() {
readMySQL();
}
public void readMySQL() {
ResultSet sql = null;
Statement state = MysqlOpen();
try {
sql = state.executeQuery("select * from sina_user_weibos_1386622641 where id between "
+ ((taskNum - 1) * 5000) + " and " + (taskNum * 5000));
System.out.println("---------task " + taskNum + "正在執(zhí)行---------");
while (sql.next()) {
String id = sql.getString(1);
String wid = sql.getString(2);
String username = sql.getString(3);
String repostscount = sql.getString(4);
String commentscount = sql.getString(5);
String text = sql.getString(6);
String createat = sql.getString(7);
String source = sql.getString(15);
String lasttime = sql.getString(17);
System.out.println(id + "\t" + wid + "\t" + username + "\t" + repostscount + "\t" + commentscount + "\t"
+ text + "\t" + createat + "\t" + source + "\t" + lasttime);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
sql.close();
state.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
System.out.println("---------task " + taskNum + "執(zhí)行完畢---------");
}
}
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
插入排序是一種最簡單的排序方法，它的基本思想是將一個記錄插入到已經排好序的有序表中，從而一個新的、記錄數增1的有序表。本文通過圖片合示例講解了插入排序的實現(xiàn)，需要的可以了解一下2022-11-11
這篇文章主要介紹了詳解spring boot rest例子，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-03-03
這篇文章主要為大家詳細介紹了Java中synchronized的核心原理以及簡單的用法，文中的示例代碼講解詳細，感興趣的小伙伴可以跟隨小編一起學習一下2023-07-07
這篇文章主要介紹了Java基礎之switch分支結構詳解,文中有非常詳細的代碼示例,對正在學習java的小伙伴們有很大的幫助,需要的朋友可以參考下2021-05-05
Spring boot使用spring retry重試機制的方法示例
這篇文章主要介紹了Spring boot使用spring retry重試機制的方法示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-01-01
這篇文章主要介紹了Java中的日期類的相關資料，幫助大家更好的利用Java處理時間，感興趣的朋友可以了解下2020-10-10
這篇文章主要介紹了Java多線程join方法實例代碼，分享了相關代碼示例，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下2018-02-02
這篇文章主要介紹了Java?Spring?Boot請求方式與請求映射過程分析，Spring?Boot支持Rest風格：使用HTTP請求方式的動詞來表示對資源的操作2022-06-06
下面小編就為大家?guī)硪黄猺esponse對象的使用(實例講解)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-09-09
今天小編就為大家分享一篇關于Java接口名稱沖突問題的講解，小編覺得內容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-04-04