一个简单基于struts2实现的数据库查询

package cn.com; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import java.util.Random; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import com.opensymphony.xwork2.ActionSupport; import tool.DBConnect; public class TestThread extends ActionSupport { private int accessMethod = 0; private int count = 0; private int threadNum = 0; private double span = 0.0000; private static String sqlBound = "insert into TestBound (id) values(?)"; class RunThread implements Runnable { public void run() { try { Connection connection = DBConnect.getCon(); Random rand = new Random(545); if (accessMethod == 1) { PreparedStatement prepare = connection.prepareStatement(sqlBound); for (int i = 0; i < count; i++) { prepare.setInt(1, rand.nextInt(100000)); prepare.executeUpdate(); } prepare.close(); } else if (accessMethod == 2) { Statement stat = connection.createStatement(); for (int i = 0; i < count; i++) { stat.executeUpdate("insert into TestBound (id) values(" + rand.nextInt(100000) + ")"); } stat.close(); } connection.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public String execute() { try { long time = System.nanoTime(); ExecutorService exec = Executors.newFixedThreadPool(threadNum); for (int i = 0; i < threadNum; i++) { exec.execute(new RunThread()); } exec.shutdown(); while (!exec.isTerminated()) { Thread.sleep(500); } time = System.nanoTime() - time; span = (double) time / 1000000000; } catch (Exception e) { e.printStackTrace(); } return SUCCESS; } public int getAccessMethod() { return accessMethod; } public void setAccessMethod(int accessMethod) { this.accessMethod = accessMethod; } public int getCount() { return count; } public void setCount(int count) { this.count = count; } public int getThreadNum() { return threadNum; } public void setThreadNum(int threadNum) { this.threadNum = threadNum; } public double getSpan() { return span; } }