MySQL 单表插入 10w+ TPS达成(3)

     * @since 12-2-9 下午3:31

     *

     */

     int step = 100000000

     int index = Integer.valueOf(args[0])

     AtomicLong id = new AtomicLong((index - 1) * step + 1)

     TDHSClient client = new TDHSClientImpl(new InetSocketAddress("10.232.31.25", 9999), 2);

     def s = new StressTest(count: step)

     s.add({

     def _id = id.incrementAndGet()

     String table = "test"

     TDHSResponse response = client.createStatement(index).insert().use("benchmark_insert").from(table)

     .value("id", _id.toString())

     .value("k", "10000")

     .value("i", _id.toString())

     .value("c", _id.toString() + "_abcdefghijklmnopqrstuvwxyz").insert()

     if (response != null && response.getStatus() != TDHSResponseEnum.ClientStatus.OK) {

     System.out.println(response);

     }

     }, 100)

     s.run()

     client.shutdown()