jdbc批量执行SQL insert 操作

  1. package com.file;
  2. import java.io.BufferedReader;
  3. import java.io.FileReader;
  4. import java.util.ArrayList;
  5. public class ResolvFile {
  6. public static String readFileContent(String filepath) {
  7. //1.读取每一行记录，保存到List中
  8. ArrayList<String> records = new ArrayList<String>();
  9. try {
  10. BufferedReader br = new BufferedReader(new FileReader(filepath));
  11. String aRecord;
  12. while((aRecord = br.readLine())!=null){
  13. records.add(aRecord);//把读取到的每一行记录保存到List中
  14. }
  15. br.close();//用完以后关闭流
  16. } catch (Exception e) {
  17. e.printStackTrace();
  18. }
  19. //2.处理每一条记录成SQL语句或保存为对象（a.去掉字段前后的分号b.拼接成SQL或者保存为对象）
  20. ArrayList<String> recordList = new ArrayList<String>();//用于保存生成的SQL或对象
  21. for(int i = 0;i<records.size();i++) {
  22. String record = records.get(i);
  23. String[] recArray = minusQuotation(record.split(","));
  24. //拼接SQL语句或保存为对象
  25. String recordSql = getRecordSql(recArray);
  26. if (null!=recordSql) {
  27. recordList.add(recordSql);
  28. }
  29. }
  30. //3.批量执行SQL或保存对象
  31. batchExecuteSql(recordList);
  32. return null;
  33. }
  34. public static int batchExecuteSql(ArrayList<String> sqlList) {
  35. System.out.println("接下来可以执行SQL语句或保存对象");
  36. System.out.println("========批量执行SQL语句==========");
  37. System.out.println("将所有语句加入到Statment stat中");
  38. for (int i = 0;i<sqlList.size();i++) {
  39. String string = sqlList.get(i);
  40. System.out.println("通过stat.addBatch(sql)来加入语句"+i+": ‘"+string+"‘");
  41. }
  42. System.out.println("通过stat.executeBatch()来执行所有的SQL语句");
  43. System.out.println("========批量执行SQL语句结束==========");
  44. //int count = stat.executeBatch();
  45. //return count;//返回执行的语句数量
  46. return sqlList.size();
  47. }
  48. //生成每条记录的SQL
  49. public static String getRecordSql(String[] recArray) {
  50. if (null==recArray) {
  51. return null;
  52. }
  53. String recordSql = "insert into tablename (sms,no,time) values(‘"+recArray[0]+"‘,‘"+recArray[2]+"‘,‘"+recArray[5]+"‘)";
  54. return recordSql;
  55. }
  56. /**
  57. * 去掉数组中每一个元素的开头和结尾的引号
  58. * @param recArray 要处理的数组
  59. * @return 处理后的数组
  60. */
  61. public static String[] minusQuotation(String[] recArray) {
  62. for (int i = 0; i < recArray.length; i++) {
  63. String str = recArray[i];
  64. if (null!=str) {
  65. if(str.indexOf( "\"")==0)
  66. str = str.substring(1,str.length());//去掉开头的分号
  67. if(str.lastIndexOf("\"")==(str.length()-1))
  68. str = str.substring(0,str.length()-1); //去掉最后的分号
  69. }
  70. recArray[i] = str;
  71. }
  72. return recArray;
  73. }
  74. public static void main(String[] args) {
  75. String filepath = "E:\\sxySMS\\smstest.txt";
  76. readFileContent(filepath);
  77. }
  78. }
时间： 2024-10-12 16:47:09

jdbc批量执行SQL insert 操作的相关文章

JDBC 复习4 批量执行SQL

1使用jdbc进行批量执行SQL在实际的项目开发中,有时候需要向数据库发送一批SQL语句执行,这时应避免向数据库一条条的发送执行,而应采用JDBC的批处理机制,以提升执行效率. package dbex.mysql; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLExce

JDBC连接MYSQL,批量执行SQL语句或在执行一个SQL语句之前执行一个SQL语句

conn = MysqlJdbcUtils.getConnection(); Statement ps=conn.createStatement(); ps.addBatch("truncate QB_ShowCount_Asite_copy"); ps.executeBatch(); String SrcSql = "select convert(unhex(hex(convert(Community using latin1))) using utf8) as Commu

mysql数据库批量执行sql文件对数据库进行操作【windows版本】

起因: 因工作需要,在本机测试环境升级mysql数据库,需逐条执行mysql数据库的sql文件对数据库进行升级,因此找了些关于mysql的文章,对批量升级数据库所需的sql文件进行升级. 整理思路: 首先,需要对所需升级的sql所在目录的sql文件进行遍历.生成新的批量执行sql文件.想到是windows系统安装的mysql,首先想到使用bat进行sql文件的生成: 生成sql文件后,还需要使用bat文件连接到数据库,并使用新生成的sql文件进行升级. 想到升级的过程中还有可能字符集出现问题,因

SQL*PLUS中批量执行SQL语句

SQL*PLUS中批量执行SQL语句 今天由于工作的需要,要在CMD中批量执行大量的SQL语句,对于Oracle学习还处在入门阶段的我,只能硬着头皮到处去寻找资料(主要是网络资料,也包括自己的电子书),最后将所有的SQL语句一次性的执行完成. 首先,将要执行的所有的SQL语句,全部写入某个sql文件当中.例如f:\test.sql; 然后,通过通过sqlplus连接到数据库:如: SQL> sqlplus test/[email protected]; 再执行如下命令: SQL> @f:\te

mysqli扩展库应用---批量执行sql语句

1, mysqli批量执行sql语句.基本语法: $sqls=”sql1;sql2;………” mysqli::multi_query($sqls); 同一个$sqls要么是增删改语句集合,要么是查询语句的集合,查询语句和增删改最好不要混合.应用示例如下: ① 操作数据库的代码: <?php class mysqliMutiTool{ private $mysqli = null; private static $host = "10.252.158.217"; private s

批量执行SQL文件

原文:批量执行SQL文件 摘要:很多时候我们在做系统升级时需要将大量的.sql文件挨个执行,十分不方便.而且考虑到执行顺序和客服的操作方便性,能不能找到一种简单的方法来批量执行这些sql文件呢? 主要内容: 准备工作 利用osql/ocmd命令批量执行sql文件 使用master..xp_cmdshell存储过程调用osql/ocmd命令 总结 一.准备工作 既然是要批量执行sql文件,首先我们建立两个sql文件:1.sql和2.sql. 1.sql的内容: INSERT INTO dbo.Pr

批量执行sql语句

基本使用 $sqls="sql语句1;sql语句2;sql语句n"; 或 $sqls="insert into xx;";  $sqls.="insert into xx;"; $res=mysqli::multi_query($sqls); 如果$sqls 是dml 语句,则$res 返回布尔值: 如果$sqls 是dql 语句,则$res 返回多个结果集,需要使用mysqli::store_result() 和 mysqli::more_re

Shell脚本中执行sql语句操作

这篇文章主要介绍了Shell脚本中执行sql语句操作mysql的5种方法,本文讲解了将SQL语句直接嵌入到shell脚本文件中.命令行调用单独的SQL文件.使用管道符调用SQL文件等方法,需要的朋友可以参考下 对于自动化运维,诸如备份恢复之类的,DBA经常需要将SQL语句封装到shell脚本.本文描述了在Linux环境下mysql数据库中,shell脚本下调用sql语句的几种方法,供大家参考.对于脚本输出的结果美化,需要进一步完善和调整.以下为具体的示例及其方法. 1.将SQL语句直接嵌入到sh

在myeclipse中配置DB Driver(数据库用MySql)，并在myeclipse执行sql语句操作

在myeclipse中配置DB Driver(数据库用MySql),并在myeclipse执行sql语句操作 MyEclipse6.5    ,  mysq驱动jar包为mysql-connector-java-5.1.8-bin.jar 在MyEclipse中添加hibernate支持时需要用到DB Driver所以需要配置 首先选择window-->Open Perspective-->Other 出现下图:选择MyEclipse Database Explore. 点击OK后出现如下画面