-module(press).
-export([get_timestamp/0,start/3,run/3]).
-include("emysql.hrl").

-record(state,{running=0,start_time,process_count_all,sql_count_each_process}).
%% 启动ProcessCount个进程，每个进程执行SqlCountEachProcess次sql 操作
start(ProcessCount,SqlCountEachProcess,MysqlConnectionCount)->
    crypto:start(),
    application:start(emysql),
    emysql:add_pool(hello_pool, MysqlConnectionCount, "root", "root", "localhost", 3306, "mysqlslap", utf8),

    CurrentTime=get_timestamp(),
    spawn_link(?MODULE,run,[ProcessCount,SqlCountEachProcess,#state{start_time=CurrentTime,
								    process_count_all=ProcessCount,
								    sql_count_each_process=SqlCountEachProcess}])
	.


recv(#state{running=0,start_time=StartTime,
	    process_count_all=ProcessCount,
	    sql_count_each_process=SqlCountEachProcess
	   })->
    Usedtime =get_timestamp()-StartTime,
    io:format("process_count:~p sql count each process:~p used time:~p~n",[ProcessCount,SqlCountEachProcess,Usedtime]),
    emysql:remove_pool(hello_pool);
recv(#state{running=Running}=State)->
    receive
	done->
	    recv(State#state{running=Running-1})
    end
	.

run(0,_SqlCountEachProcess,#state{}=State)->
    recv(State);
run(ProcessCount,SqlCountEachProcess,#state{running=Running}=State) ->
    Parent =self(),
    spawn(fun()-> run_sql(SqlCountEachProcess,Parent)end),
    run(ProcessCount-1,SqlCountEachProcess,State#state{running=Running+1})
	.

run_sql(0,Parent)->
    Parent!done;
run_sql(SqlCountEachProcess,Parent) ->
    test2(),
    run_sql(SqlCountEachProcess-1 ,Parent)
	.


test2()->
    %%"insert into tbl_test(  accountId,  accountType,  playerId,  headHeroId,  playerLevel,  playerName,  logTime,  clientVersion,  clientType,  issuers,  flashPlayerVersion,  connectType,  gameServerName,  ipAddr,  onOffType  ) values(1,1,1,1,1,'name','1989-01-26','ver','t','dd',1,1,'name','localhost',1)"
    %% "call insert_tbl_test(1,1,1,1,1,'name','1989-01-26','ver','t','dd',1,1,'name','localhost',1);"
    Result=emysql:execute(hello_pool,<< "call insert_tbl_test(1,1,1,1,1,'name','1989-01-26','ver','t','dd',1,1,'name','localhost',1);">>),
    case Result of
	Rec when is_record(Rec ,ok_packet) ->
	    ok;
	Rec when is_record(Rec ,error_packet) ->
	    io:format("~p~n",[Result])
    end

    %% %% Pid=global:whereis_name(emysql_center)
	.
get_timestamp() ->
    {Mega,Sec,Micro} = erlang:now(),
    ((Mega*1000000+Sec)*1000000+Micro)/1000.

启用10000个erlang进程，每个进程向emysql发一条sql(存储过程),最后一个参数是emysql连接池
里只开一个mysql连接
press:start(10000,1,1).

测试结果显示大概用了8秒，大概是比单纯的mysql测试慢3~4倍 (7583/2496=3.45)
(emacsdd@jf.org)4> press:start(10000,1,1).
process_count:10000 sql count each process:1 used time:7583.25390625

起用一个进程，此进程向emysql发送10000条sql语句
1>  press:start(1,10000,1).
process_count:1 sql count each process:10000 used time:8632.112060546875

1>  press:start(10,1000,1).
process_count:10 sql count each process:1000 used time:7520.348876953125

1>  press:start(100,100,1).
process_count:100 sql count each process:100 used time:7613.68896484375

import java.sql.Date;
import java.sql.Types;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
public class TestMysqlConn {
    public static void main(String[] args) throws Exception {
        // Class.forName("com.mysql.jdbc.Driver");
        Class.forName("org.gjt.mm.mysql.Driver");
        long start= System.currentTimeMillis();
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mysqlslap?user=root&password=root");
        // call insert_tbl_test(1,1,1,1,1,'name','1989-01-26','ver','t','dd',1,1,'name','localhost',1)
        CallableStatement cs = conn.prepareCall("{call insert_tbl_test(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)}");
        cs.setInt(1 , 1);
        cs.setInt(2 , 1);
        cs.setInt(3 , 1);
        cs.setInt(4 , 1);
        cs.setInt(5 , 1);
        cs.setString(6 , "name");
        cs.setDate(7 , new Date(1989 , 1 , 26));
        cs.setString(8 , "ver");
        cs.setString(9 , "t");
        cs.setString(10 , "dd");
        cs.setInt(11 ,1);
        cs.setInt(12 ,1);
        cs.setString(13 , "name");
        cs.setString(14 , "localhost");
        cs.setInt(15 , 1);
        for (int i = 0; i < 10000; i++) {
            cs.executeUpdate();
        }
        long end= System.currentTimeMillis();
        System.out.println(end-start);

    }
}