TestInsert

package com.test.demo.autodemo;

import org.omg.PortableInterceptor.SYSTEM_EXCEPTION;

import java.sql.*;

import java.util.Random;

public class TestInsert {

private Stringurl ="jdbc:mysql://localhost:3306/test01";

    private Stringuser ="root";

    private Stringpassword ="123456";

    //创建数据库连接

    static Connectionconn =null;

    //创建预编译语句对象

    static PreparedStatementpstmt =null;

    //创建一个结果集

    static ResultSetresult =null;

    /**

* 初始化数据库连接驱动

*/

    private static void initJdbc() {

try {

Class.forName("com.mysql.jdbc.Driver"); //加载驱动程序

            String url ="jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf-8"; //数据库连接信息

            String user ="root"; //数据库用户名

            String pass ="666888"; //数据库密码

            conn = DriverManager.getConnection(url, user, pass); //获取连接

            System.out.println("linked successfully");

        }catch (ClassNotFoundException e) {

e.printStackTrace();

        }catch (SQLException e) {

e.printStackTrace();

        }

}

public  static  void  Test()throws SQLException {

String sql ="INSERT INTO demo(aaa,bbb,ccc,name,action) VALUES(?,?,?,CONCAT('name',?),?)";

        pstmt=conn.prepareStatement(sql);

        Long startTime= System.currentTimeMillis();

        Random random=new Random();

        int a;

        for(int i=1;i<=3;i++){

a=random.nextInt(10);

            String a1="a"+i;

            String b1="b"+i;

            String c1="c"+i;

            pstmt.setString(1,a1);

            pstmt.setString(2,b1);

            pstmt.setString(3,c1);

            pstmt.setInt(4,i);

            pstmt.setString(5,"D");

            pstmt.execute();

        }

System.out.println("insert data success!");

        Long endTime = System.currentTimeMillis();

        System.out.println("OK,用时：" + (endTime - startTime));

    }

//关闭数据库连接

    public static void closeCon(Connection con){

if(con !=null){

try{

con.close();

            }catch(Exception e){

e.printStackTrace();

            }

}

}

public static void main(String[] args)throws SQLException {

initJdbc();

        Test();

        closeCon(conn);

    }

}