使用testng多线程来测试成交编号重复的问题

1.首先编写一个测试用的 function

CREATE OR REPLACE FUNCTION getDealmainNo_test(dealdate        IN varchar2,
                                         productcodename in varchar2)
/***********************************************************
  * linc 2018-01-09
  * 方法：获取序列编号
  * 入参：成交日期，产品代码
  * 返回：序列编号
  ***********************************************************/
 RETURN varchar2 AS
  today     varchar2(10);
  seqno     integer;
  begindate varchar2(20) := dealdate || ' 00:00:00';
  enddate   varchar2(20) := dealdate || ' 23:59:59';
  seqnoname varchar2(30);
  pragma autonomous_transaction;
BEGIN
  seqno := 0;
  select to_char(sysdate, 'yyyy-mm-dd') into today from dual;
  if today = dealdate then
    execute immediate 'select seq_' || productcodename ||
                      '_no.nextval from dual'
      into seqno;
  else
    begin
      select nvl(max(to_number(substr(s.tno, -6))), 0) + 1
        into seqno
        from (select s.tno
                from table_A s
               where s.dealdate between
                     to_date(begindate, 'yyyy-mm-dd hh24:mi:ss') and
                     to_date(enddate, 'yyyy-mm-dd hh24:mi:ss')
                 and s.tcode = productcodename) s  ;

    exception
      when others then
        return '';
    end;
  end if;
  seqnoname := productcodename || replace(dealdate, '-', '') ||
               lpad(seqno, 6, '0');
  RETURN seqnoname;
END getDealmainNo_test;

2.使用java对func进行调用 每次获得一个最大的成交编号 ；

package main.java.javaprictice;

import main.java.C3P0XmlSimplify;
import org.testng.annotations.Test;

import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * Created by linbo.yang on 2018/1/9.
 */
public class CallOracleFunc {
    Connection conn = null;
    CallableStatement callableStatement = null;
    PreparedStatement ps = null;
    ResultSet rs;

    public Integer save(String no) {
        
        Integer rowCount=null ;
        String sql="insert into table_A(dealdate,tno,tdate,tcode) values(?,?,?,?)  ";
        conn = C3P0XmlSimplify.getInstance().getConnection();
        //ddate
        SimpleDateFormat df =new SimpleDateFormat("yyyy-MM-dd HH24:mm:ss");
        String date = df.format(new Date());
        Timestamp timestamp = Timestamp.valueOf(date);
//dealdate
        SimpleDateFormat df1 =new SimpleDateFormat("yyyy-MM-dd");
        String dealdate = df1.format(new Date());


        try {
            ps = conn.prepareStatement(sql);
            ps.setDate(1,java.sql.Date.valueOf("2018-01-08"));
            ps.setString(2,no);
            ps.setTimestamp(3,timestamp);
            ps.setString(4,"IBO");
            rowCount=  ps.executeUpdate();
            System.out.println("rowCount"+rowCount);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            C3P0XmlSimplify.releaseSources(conn);
            return rowCount ;
        }


    }





    public String getDealmainNo() {
        String string = null;
        try {

            conn = C3P0XmlSimplify.getInstance().getConnection();
           /*  ?=call getDealmainNo(?,?);
           *  第一个问号（？） 代表输入值，但要制定输入类型:callableStatement.registerOutParameter(1, Types.VARCHAR);
           *  第二个问号（？） 代表输入值，通过callableStatement.setString（）方法类制定入参的类型 ；
           *  。。。。。。。
           * */
            callableStatement = conn.prepareCall("{?=call getDealmainNo_test(?,?)}");
            callableStatement.registerOutParameter(1, Types.VARCHAR);
            callableStatement.setString(2, "2018-01-08");
            callableStatement.setString(3, "IBO");
            callableStatement.execute();
            string = callableStatement.getString(1);
            System.out.println(string);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            C3P0XmlSimplify.releaseSources(conn);
            return string;
        }
    }
@Test(threadPoolSize = 3,invocationCount = 10,timeOut = 100000)
    public  void getDealmainNo_() {
    CallOracleFunc c=new CallOracleFunc();
    String dealmainNo = c.getDealmainNo();
    Integer row = c.save(dealmainNo);
    System.out.println("dealmainNo="+dealmainNo+"  ;row="+row);

    }


    public static void main(String[] args) {
        CallOracleFunc c=new CallOracleFunc();
        String dealmainNo = c.getDealmainNo();
        Integer row = c.save(dealmainNo);
        System.out.println("dealmainNo="+dealmainNo+"  ;row="+row);


    }


}

 --数据的相关脚本

   create table table_A(
   tid number ,
   dealdate date ,
   tcode varchar2(100),
   tno varchar2(100),
   tdate timestamp
   ) ;         
    drop table table_A ;        
   select * from table_A  t where t.tid is null ;
   delete table_A  t where t.tid is null ;
 insert into table_A
   select v.ID, 
   v.DEALDATE,
   v.PRODUCTCODE,
   v.NO, 
   v.CREATETIME
    from v_product_deal_main v ;
    insert into table_A(tno,tdate) values(?,?) ;

      select nvl(max(to_number(substr(s.tno, -6))), 0) + 1
        from (select s.tno
                from table_A s
               where s.dealdate between
                     to_date('2018-01-08 00:00:00', 'yyyy-mm-dd hh24:mi:ss') and
                     to_date('2018-01-08 23:00:00', 'yyyy-mm-dd hh24:mi:ss')
                 and s.tcode = 'IBO') s