Warning: mkdir(): No space left on device in /data/discuz/upload/source/class/class_core.php on line 91
java对数据库操作-java,对,数据库,操作-IT技术擎-最棒的IT web技术交流社区-( it.techqing.com)
设为首页收藏本站

IT技术擎 - 最棒的IT web技术交流社区

 找回密码
 注册为IT技术擎人

QQ登录

只需一步,快速开始

搜索
热搜: php h5 jquery
查看: 8|回复: 0

[未分类] java对数据库操作

[复制链接]

3万

主题

3万

帖子

10万

积分

版主

Rank: 7Rank: 7Rank: 7

积分
108882
发表于 2020-1-21 20:40:22 | 显示全部楼层 |阅读模式
  1. /** * 创建文件数据表 * * @param splitstr */ publicvoidCreateTable(String splitstr){ String sqsl ="CREATE TABLE "+"dmp_mp_"+splitstr +" like dmp_mp_demo"; jdbcTemplate.execute(sqsl); log.info("创建表[{}]完成","dmp_mp_"+splitstr); }
复制代码
  1. /** * 将文件中的数据读取到数据库中 * * @param filename * @throws Exception */ publicbooleanAddUserToDatebase(String filename)throwsException { log.info("开始将文件{}存入数据库中",filename); File file =newFile(filenames +filename); if(file.length() <
  2. 10){ log.info("文件长度不大于10"); returnfalse; }
  3. else{ Charset charset =Charset.defaultCharset(); BufferedReader bufferedReader =newBufferedReader(newInputStreamReader(newFileInputStream(file),charset)); //sql语句 StringBuffer sqls =newStringBuffer("START TRANSACTION; "); //当前行数据 String line =""; String decrypt =""; //标识每5000条提交一次数据 intindex =0; //去掉文件后缀 String splitstr =Splitstr(filename); //判断成功多少 intindex2 =0; while((line =bufferedReader.readLine())!=null){ decrypt =AesEncode.Decrypt(line); //判断是否乱码 true 为正常 if(IsGarbled(decrypt)){ sqls.append("INSERT INTO dmp_mp_"+splitstr +" (`account`) VALUES ('"+decrypt.trim()+"');"); index++; if(index ==5000){ index2 +=5000; index =0; sqls.append("COMMIT;"); jdbcTemplate.execute(sqls.toString()); sqls =newStringBuffer("START TRANSACTION; "); } }
  4. } if(index >
  5. 0 & &index <
  6. 5000){ sqls.append("COMMIT;"); index2 +=index; jdbcTemplate.execute(sqls.toString()); } log.info("成功导入数据[{}]条",index2); bufferedReader.close(); returntrue; }
  7. }
复制代码
  1. /** * 判断当前字符是否乱码 * * @param s 判断的内容 * @return true 为正常 false为乱码 */ publicstaticbooleanIsGarbled(String s){ if(s !=null & &
  2. !(Charset.forName("GBK").newEncoder().canEncode(s))){ returnfalse; }
  3. else{ returntrue; } }
复制代码

  • 点赞  

  • 收藏

  • 分享


    • 文章举报
  
梵墨白发布了9 篇原创文章· 获赞 0· 访问量 40 私信 关注



上一篇:【vue学习】—slot插槽的使用
下一篇:II7建站相关命令
该用户未在地球留下任何的痕迹

本版积分规则

QQ|小黑屋|帮助|IT技术擎 ( 沪ICP备15054863号  

GMT+8, 2020-2-27 08:49

Powered by Discuz! X3.2 Licensed

© 2001-2013 Comsenz Inc.

快速回复 返回顶部 返回列表