可以实现的，使用java写个类，生成：
package com.didi.utils;
/**
*
*
*
*/
public class GCounter {
// 定义一个私有构造方法
private GCounter() {
}
private static volatile long counter=10000;
synchronized public static String getIstance(int processNumber) {
counter=counter+1;
return processNumber+"->"+counter;
}
}
=====
调用的groovy脚本：
import static net.grinder.script.Grinder.grinder
import static org.junit.Assert.*
import static org.hamcrest.Matchers.*
import net.grinder.plugin.http.HTTPRequest
import net.grinder.plugin.http.HTTPPluginControl
import net.grinder.script.GTest
import net.grinder.script.Grinder
import net.grinder.scriptengine.groovy.junit.GrinderRunner
import net.grinder.scriptengine.groovy.junit.annotation.BeforeProcess
import net.grinder.scriptengine.groovy.junit.annotation.BeforeThread
import static net.grinder.util.GrinderUtils.* // You can use this if you're using nGrinder after 3.2.3
import org.junit.Before
import org.junit.BeforeClass
import org.junit.Test
import org.junit.runner.RunWith
import java.util.Date
import java.util.List
import java.util.ArrayList
import HTTPClient.Cookie
import HTTPClient.CookieModule
import HTTPClient.HTTPResponse
import HTTPClient.NVPair
import java.sql.DriverManager
import java.sql.SQLException
import java.sql.Statement
import java.sql.ResultSet
import com.mysql.jdbc.Connection
import com.didi.utils.GCounter
import com.didi.utils.JavaStackTrace
/**
* A simple example using the HTTP plugin that shows the retrieval of a
* single page via HTTP.
*
* This script is automatically generated by ngrinder.
*
* @author admin
*/
@RunWith(GrinderRunner)
class TestRunner {
public static String msg
public static GTest test
public static HTTPRequest request
public static NVPair[] headers = []
public static NVPair[] params = []
public static Cookie[] cookies = []
//增加数据
public static Boolean addUser(){
Connection con = null
Statement stmt = null
ResultSet rs = null
boolean status=true
String msg=""
//def GCounter de=new GCounter();
int agentNumber = grinder.agentNumber
int processNumber = grinder.processNumber
int threadNumber = grinder.threadNumber
//long threadId = GrinderUtils.threadUniqId
String counter=GCounter.getIstance(processNumber);
try{
Class.forName("com.mysql.jdbc.Driver");
con = DriverManager.getConnection("jdbc:mysql://10.94.66.30:3309/zblog",
"root", "123456");
stmt = con.createStatement();
//stmt = con.createStatement();
String name="A_"+counter+"|"+agentNumber+"_"+processNumber+"_"+threadNumber;
String pass="PW_"+counter;
String sql="insert into user(`username`,`password`) values ('"+name+"','"+pass+"')";
stmt.executeUpdate(sql);
}catch(SQLException e){
status=false;
msg=JavaStackTrace.errorStack2String(e);
grinder.logger.info("错误："+msg);
}catch(ClassNotFoundException e){
status=false;
msg=JavaStackTrace.errorStack2String(e);
grinder.logger.info("错误："+msg);
}finally{
try{stmt.close();}catch(Exception e){}
try{con.close();}catch(Exception e){}
}
return status
}
public static void jdbcTest() {
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try{
Class.forName("com.mysql.jdbc.Driver");
con = DriverManager.getConnection("jdbc:mysql://10.94.66.30:3309/zblog",
"root", "123456");
stmt = con.createStatement();
rs = stmt.executeQuery("select * from user");
while (rs.next()) {
System.out.println("user id: " + rs.getLong(1) +
" username: " + rs.getString(2) +
" pass: " + rs.getString(3));
}
}catch(SQLException e){
e.printStackTrace();
}catch(ClassNotFoundException e){
e.printStackTrace();
}finally{
try{rs.close();}catch(Exception e){}
try{stmt.close();}catch(Exception e){}
try{con.close();}catch(Exception e){}
}
}
@BeforeProcess
public static void beforeProcess() {
HTTPPluginControl.getConnectionDefaults().timeout = 6000
test = new GTest(1, "Test1")
request = new HTTPRequest()
grinder.logger.info("before process.");
}
@BeforeThread
public void beforeThread() {
test.record(this, "test")
grinder.statistics.delayReports=true;
grinder.logger.info("before thread.");
}
@Before
public void before() {
request.setHeaders(headers)
cookies.each { CookieModule.addCookie(it, HTTPPluginControl.getThreadHTTPClientContext()) }
grinder.logger.info("before thread. init headers and cookies");
}
@Test
public void test(){
//HTTPResponse result = request.GET("
http://10.94.120.205:8866/ci/login?from=%2Fci%2F", params)
//jdbcTest();
def status=addUser();
if(status==false){
grinder.logger.info("添加用户失败。。。");
assertThat(100, is(200));
}else{
assertThat(200, is(200));
}
//if (result.statusCode == 301 || result.statusCode == 302 || result.statusCode == 403 || status==false) {
// grinder.logger.warn("Warning. The response may not be correct. The response code was {}.", result.statusCode);
//} else {
//
//}
}
}
Locked
