简单的更容易遗忘，除非持久化输出
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class MysqlDemo { static { try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } } public static void run_test(String url, String user, String pwd){ try { System.out.println(String.format("url: %s", url)); Connection conn = DriverManager.getConnection(url, user, pwd); Statement stmt1 = conn.createStatement(); ResultSet rs; rs = stmt1.executeQuery("show tables"); while(rs.next()){ System.out.println(rs.getString(1)); } //持续插入数据 int rows=0; stmt1.executeUpdate("drop database if exists jdbc_test"); stmt1.executeUpdate("create database jdbc_test"); stmt1.executeUpdate("create table jdbc_test.tb_jdbc(id bigint key, c1 varchar(128))"); for(int i=1;i<1000;i++){ String val = String.format("(%d, 'jdbc_abc_%d')", i, i); rows = stmt1.executeUpdate("replace into jdbc_test.tb_jdbc(id, c1) values" + val); if(rows != 0){ System.out.println("insert " + val); } Thread.sleep(1000); } }catch (Exception e) { System.out.println(e.toString()); } } public static void main(String[] args){ run_test(args[0], args[1], args[2]); } } |
在idea中创建一个普通的项目，编译后打包输出成mysql_jdbc_demo.jar文件，然后这么执行 java -cp mysql-connector-java8.jar:mysql_jdbc_demo.jar MysqlDemo "jdbc:mysql://192.168.2.199:3306 […]