RE: jdbc连接数据库，record无测试结果返回

Posted by lianyadong on
URL: http://ngrinder.373.s1.nabble.com/jdbc-record-tp871p2227.html

使用这个脚本：
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 {
                //
                //}
        }
}