本文主要介绍了MYSQL读写性能测试的简单记录，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
进行测试之前首先保证你已经可以对数据库进行读写：参见
要求：对MYSQL数据库的读写读写性能进行测试。支持多并发、支持调整事物提交记录数。
注意事项：
要运行测试需要
1. 需要修改数据库的配置信息DB_DRIVER、DB_URL、DB_USERNAME、DB_PASSWORD；
2.DB_URL中还要指定哪个数据库。“dbc:mysql://localhost:3306/test”其中的test就是我锁用的那个数据库；
3. 修改TABLE_NAME指定数据库测试的表名(此处是student表)，测试程序会查询这个表的定义来生成写入SQL语句；
4.还有此语句 if (column.equalsIgnoreCase("name")) 中的那么为你创建的表的key，这个也要对用调整过来；
5. 修改concurrentList指定需要测试并发数列表，默认测试1,5,10,20四种并发数；
6. 修改batchSizeList指定每次测试的事务提交记录数据，默认是100,200,500,1000
最后运行测试，会生成类似下面的结果：
测试完成后检查该student表，输入select * from student; 可以看到源源不断的数据的输出，插入的表项太多了。
具体查了多少数据呢？使用select count(*) from student;查看。
可能遇到的问题：
（1）UUID.randomUUID().toString()生成的主键会很长，因此主键name的长度应设的长一些否则会出现如下报错：
由上上截图可以看到生成的主键还是蛮长的。
（2）每次测试的时候最好将上一次测试的table删除重新建一个。否则测试的数据之间相差很大。
建立student表的SQL语句如下：
--删除student表的SQL语句 drop table student; --查询表格项数大小的语句 select count(*) from student; --建立student表，注意key的预留空间较大 create table student (name varchar(120) not null, goal varchar(20) not null, primary key(name));
程序代码如下：
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.sql.Timestamp; import java.sql.Types; import java.util.ArrayList; import java.util.Calendar; import java.util.Collections; import java.util.Formatter; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Random; import java.util.UUID; import java.util.concurrent.CountDownLatch; import java.util.logging.Level; import java.util.logging.Logger; public class InsertTest { private static Logger logger = Logger.getLogger(InsertTest.class.getName()); //驱动程序名 private static final String DB_DRIVER = "com.mysql.cj.jdbc.Driver"; //URL指向要访问的数据库名mysql private static final String DB_URL = "jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true&useSSL=false&serverTimezone=UTC"; //MySQL配置时的用户名 private static final String DB_USERNAME = "root"; //MySQL配置时的密码 private static final String DB_PASSWORD = "…………"; private static Random random = new Random(10000); //我们要测试的表的名称 private static final String TABLE_NAME = "student"; private int batchSize;//一批提交的事务数 private int concurrent;// private int sampling;// public static void main(String[] args) throws Exception { printHeader(); int[] concurrentList = new int[]{1, 5, 10, 20};//默认测试1，5，10，20个并发 int[] batchSizeList = new int[] {100, 200, 500, 1000};//一批提交的事务数 for (int concurrent : concurrentList) { for (int batchSize : batchSizeList) { //对以上每种组合都run一次 new InsertTest(batchSize, concurrent).run(true); } Thread.sleep(10000); } } /*-----------InsertTest类的构造函数一-------------*/ public InsertTest(final int batchSize, final int concurrent) throws Exception { this.batchSize = batchSize; this.concurrent = concurrent; this.sampling = 100; } /*-----------InsertTest类的构造函数二-------------*/ public InsertTest(final int batchSize, final int concurrent, final int sampling) throws Exception { this.batchSize = batchSize; this.concurrent = concurrent; this.sampling = sampling; } /*-----------开始运行run方法-------------*/ public void run(boolean printResult) throws Exception { final List results = Collections.synchronizedList(new ArrayList()); final CountDownLatch startGate = new CountDownLatch(concurrent); final CountDownLatch endGate = new CountDownLatch(concurrent); for (int idxConcurrent = 0; idxConcurrent columns = queryTableColumns(conn); String insertSQL = generateInsertSQL(columns); PreparedStatement ps = conn.prepareStatement(insertSQL); try { long start = System.currentTimeMillis(); for (int i = 0; i columns) throws Exception { try { for (int idx = 0; idx columns) throws SQLException { StringBuilder sb = new StringBuilder(); StringBuffer sbColumns = new StringBuffer(); StringBuffer sbValues = new StringBuffer(); sb.append("INSERT INTO ").append(TABLE_NAME); for (String column : columns.keySet()) { if (sbColumns.length() > 0) { sbColumns.append(","); sbValues.append(","); } sbColumns.append(column); sbValues.append("?"); } sb.append("(").append(sbColumns).append(")"); sb.append("VALUES"); sb.append("(").append(sbValues).append(")"); return sb.toString(); } private Map queryTableColumns(Connection conn) throws Exception { Map columns = new LinkedHashMap(); String sql = "SELECT * FROM " + TABLE_NAME + " WHERE 1=0"; Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(sql); ResultSetMetaData rsmd = rs.getMetaData(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { columns.put(rsmd.getColumnName(i), rsmd.getColumnType(i)); } return columns; } //生成列值 private Object generateColumnValue(int type) { Object obj = null; switch (type) { case Types.DECIMAL: case Types.NUMERIC: case Types.DOUBLE: case Types.FLOAT: case Types.REAL: case Types.BIGINT: case Types.TINYINT: case Types.SMALLINT: case Types.INTEGER: obj = random.nextInt(10000); break; case Types.DATE: obj = Calendar.getInstance().getTime(); break; case Types.TIMESTAMP: obj = new Timestamp(System.currentTimeMillis()); break; default: obj = String.valueOf(random.nextInt(10000)); break; } return obj; } //连接MYSQL数据库。 private Connection getConnection() throws Exception { Class.forName(DB_DRIVER); Connection conn = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD); conn.setAutoCommit(false); return conn; } //打印出表头（即列的信息） private static void printHeader() { StringBuilder sb = new StringBuilder(); sb.append("\n"); sb.append(new Formatter().format("%15s|%15s|%15s|%15s|%15s", "BATCH_SIZE", "CONCURRENT", "AVG (r/s)", "MIN (r/s)", "MAX (r/s)")); System.out.println(sb.toString()); } //打印每次跑完后的统计信息 private static void printResult(int batch, int concurrent, List results) { Long total = Long.valueOf(0); for (Long result : results) { total += result; } StringBuilder sb = new StringBuilder(); sb.append(new Formatter().format("%15s|%15s|%15s|%15s|%15s", batch, concurrent, (total/results.size()), results.get(0), results.get(results.size() - 1))); System.out.println(sb.toString()); } } 到此这篇关于MYSQL读写性能测试的简单记录的文章就介绍到这了,更多相关MYSQL读写性能测试内容请搜索0133技术站以前的文章或继续浏览下面的相关文章希望大家以后多多支持0133技术站！
以上就是MYSQL读写性能测试的简单记录的详细内容，更多请关注0133技术站其它相关文章！
