文章来自:http://blog.csdn.net/kongxx/article/details/42360663
今天工作需要要写一个小工具来测试一下数据库的写入性能,需要支持多并发,并且支持调整事务提交记录大小,所以就用Java写了一个,就一个类,比较简单但是基本功能都有了,下面看看代码实现
- 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.ibm.db2.jcc.DB2Driver";
- private static final String DB_URL = "jdbc:db2://9.111.251.152:50000/padb";
- private static final String DB_USERNAME = "db2inst";
- private static final String DB_PASSWORD = "Letmein";
- private static Random random = new Random(10000);
- private static final String TABLE_NAME = "BENCHMARK";
- 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};
- int[] batchSizeList = new int[] {1000, 2000, 5000, 10000};
- for (int concurrent : concurrentList) {
- for (int batchSize : batchSizeList) {
- new InsertTest(batchSize, concurrent).run(true);
- }
- Thread.sleep(10000);
- }
- }
- public InsertTest(final int batchSize, final int concurrent) throws Exception {
- this.batchSize = batchSize;
- this.concurrent = concurrent;
- this.sampling = 100;
- }
- public InsertTest(final int batchSize, final int concurrent, final int sampling) throws Exception {
- this.batchSize = batchSize;
- this.concurrent = concurrent;
- this.sampling = sampling;
- }
- public void run(boolean printResult) throws Exception {
- final List<Long> results = Collections.synchronizedList(new ArrayList<Long>());
- final CountDownLatch startGate = new CountDownLatch(concurrent);
- final CountDownLatch endGate = new CountDownLatch(concurrent);
- for (int idxConcurrent = 0; idxConcurrent < concurrent; idxConcurrent++) {
- new Thread(new Runnable() {
- public void run() {
- startGate.countDown();
- try {
- long time = execute();
- long avg = batchSize * sampling * 1000 / time;;
- results.add(Long.valueOf(avg));
- } catch(Exception ex) {
- ex.printStackTrace();
- } finally {
- endGate.countDown();
- }
- }
- }).start();
- }
- endGate.await();
- Collections.sort(results);
- if (printResult) {
- printResult(batchSize, concurrent, results);
- }
- }
- public long execute() throws Exception {
- Connection conn = getConnection();
- Map<String, Integer> columns = queryTableColumns(conn);
- String insertSQL = generateInsertSQL(columns);
- PreparedStatement ps = conn.prepareStatement(insertSQL);
- try {
- long start = System.currentTimeMillis();
- for (int i = 0; i < sampling; i++) {
- execute(conn, ps, columns);
- }
- long stop = System.currentTimeMillis();
- return stop - start;
- } catch(Exception ex) {
- logger.log(Level.SEVERE, null, ex);
- conn.rollback();
- conn.close();
- throw ex;
- } finally {
- conn.close();
- }
- }
- public void execute(Connection conn, PreparedStatement ps, Map<String, Integer> columns) throws Exception {
- try {
- for (int idx = 0; idx < batchSize; idx++) {
- int idxColumn = 1;
- for (String column : columns.keySet()) {
- if (column.equalsIgnoreCase("ID")) {
- ps.setObject(idxColumn, UUID.randomUUID().toString());
- } else {
- ps.setObject(idxColumn, generateColumnValue(columns.get(column)));
- }
- idxColumn ++;
- }
- ps.addBatch();
- }
- ps.executeBatch();
- conn.commit();
- ps.clearBatch();
- } catch (SQLException ex) {
- logger.log(Level.SEVERE, null, ex);
- if (null != ex.getNextException()) {
- logger.log(Level.SEVERE, null, ex.getNextException());
- }
- conn.rollback();
- throw ex;
- }
- }
- private String generateInsertSQL(Map<String, Integer> 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<String, Integer> queryTableColumns(Connection conn) throws Exception {
- Map<String, Integer> columns = new LinkedHashMap<String, Integer>();
- 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;
- }
- 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<Long> 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());
- }
- }
要运行测试需要
1. 修改数据库的配置信息
2. 修改TABLE_NAME指定数据库里需要测试的表名,测试程序会查询这个表的定义来生成写入SQL语句
3. 修改concurrentList指定需要测试并发数列表,默认测试1,5,10,20个并发
4. 修改batchSizeList指定每次测试的事务提交记录数据,默认是1000,2000,5000,10000
最后运行测试,会生成类似下面的结果
- BATCH_SIZE| CONCURRENT| AVG (r/s)| MIN (r/s)| MAX (r/s)
- 1000| 1| ...| ...| ...
- 2000| 1| ...| ...| ...
- 5000| 1| ...| ...| ...
- 10000| 1| ...| ...| ...
- 1000| 5| ...| ...| ...
- 2000| 5| ...| ...| ...
- 5000| 5| ...| ...| ...
- 10000| 5| ...| ...| ...
相关推荐
总结来说,“db数据库写入性能测试”是对数据库在大量数据写入场景下的性能评估,通过工具如YCSB,我们可以深入理解数据库的性能瓶颈,优化配置,确保在高负载环境下仍能保持高效稳定的服务。对于MongoDB和MySQL这样...
Loadrunner测试数据库性能、测试SQL语句性能的脚本例子 ...该脚本例子可以用来测试MySQL数据库的性能和SQL语句的性能, Loadrunner是一个功能强大且灵活的性能测试工具,可以用来测试各种类型的系统。
Benchmark Factory是Quest公司推出的一个性能测试工具,旨在帮助用户快速、简单地对数据库进行性能测试。该工具提供了向导式的操作界面,让用户可以轻松地创建测试场景、设计测试模型、构建SQL语句,并执行性能测试...
- 推荐使用MySQLslap作为性能测试工具。 5. **操作系统选择**: - 本案例使用CentOS 5.0 x86_64作为操作系统。 #### 七、测试实施步骤 1. **系统内存限制**: - 通过修改`grub.conf`文件中的`mem=1G`参数,限制...
具体到数据写入性能测试中,测试案例包括每秒并发写入20万实时数据的测试,以及给定20万点急速写入1200万条实时数据的测试,测试了不同线程下的数据入库响应耗时、数据库服务器压力、CPU和内存的占用率以及磁盘写入...
8. **监控与调优**:持续监控数据库性能,使用分析工具如JMX或h2database的内置监控功能,找出性能瓶颈并进行针对性优化。 通过这些策略,h2database能够在内存中快速处理大量数据,从而解决IO瓶颈问题,提高系统...
这款测试工具能够帮助用户验证与这些数据库系统的连接,确保数据的正常读取、写入和管理。 在标签中,“数据库”涵盖了数据存储、管理和查询的整个领域,它涉及到表的设计、索引的创建、事务处理、安全性设置等多个...
在.NET开发环境中,数据库测试数据的生成是必不可少的环节,特别是在进行性能测试、压力测试或者功能验证时。本文将详细讲解如何使用一个自定义的.NET工具类来高效地生成数据库测试数据,支持包括MSSQL、Oracle、...
3. Sysbench:一款开源的性能测试工具,可以模拟多用户并发访问数据库的过程,测试 MySQL 服务器的 OLTP 性能、CPU 性能和磁盘 I/O 性能等指标。 七、结论 MySQL 数据库性能优化是一个持续不断的过程。通过调整...
OPS性能测试工具是一种专门用于评估系统在执行OPS(Operations Per Second)操作时的性能的软件。在多线程环境下,这种工具能够同时进行大量的读写文件操作,从而更准确地模拟真实工作负载并分析系统的并发处理能力...
MySQL到SQL Server转换工具包是针对数据库管理员和开发人员的一款实用工具,它的主要功能是将MySQL数据库结构和数据无缝地迁移到SQL Server环境中。这样的转换对于那些需要在不同数据库系统间进行迁移或整合项目的...
除了基本的数据库写入,log4net还支持自定义数据库适配器,允许你扩展其功能,以适应特定的数据库系统或特殊需求。此外,考虑到性能和可扩展性,还可以使用缓冲策略,如BulkInsert,来批量处理日志记录,减少对...
本工具使用ADO方式来操作数据库,意味着它可以连接到多种类型的数据库,如MS SQL Server、Access等,通过ADO提供的接口执行SQL语句,进行数据的读取、写入、更新和删除等操作。ADO的优势在于其简单易用,且性能高效...
在互联网公司中,数据库性能测试是确保系统稳定、高效运行的关键环节。生产环境数据库的性能测试涉及多个层面,包括但不限于数据库设计、查询优化、硬件配置、并发处理能力以及故障恢复策略。下面将详细阐述这些重要...
总的来说,Sqlstress作为一款免费的SQL性能测试工具,其易用性和实用性使其在数据库性能测试领域占有重要地位。通过熟练掌握Sqlstress的使用,数据库管理员能够更好地管理和优化SQL Server,确保系统的高效稳定运行...
- **性能测试**:在大规模数据或高并发场景下测试数据库连接,检查性能是否满足需求,例如查询速度、内存占用等。 - **断开和重新连接**:测试断开和重新连接数据库的功能,确保程序在连接丢失后能恢复连接。 通过...
JMeter是广泛使用的性能测试工具,适用于接口和Web应用的压测。以下是使用JMeter时的一些关键点: 1. **编写接口测试代码**:编写接口测试代码是为了验证接口功能的正确性,便于在JMeter中构建压测脚本。 2. **调用...
在实际工程实践中,为了测试和评价分布式关系型数据库的RPO,可以搭建测试环境,并利用测试工具如LoadRunner来获取相关性能指标。具体方法包括记录平均响应时间、每秒虚拟用户HTTP请求数、Tomcat日志等,通过对这些...
使用这样的测试数据库,用户可以在不干扰生产环境的情况下,安全地试验新功能、调试代码或进行性能基准测试。 "test_db"很可能是数据库的名称,而其他出现在标签中的"mysqltest_db", "mysql_test_db", "mysql-test-...