java读取本地txt文件并插入数据库

  1. package com.cniia.ny.web.control.configManage;
  2. import java.io.BufferedReader;
  3. import java.io.File;
  4. import java.io.FileReader;
  5. import java.io.IOException;
  6. import java.sql.Connection;
  7. import java.sql.DriverManager;
  8. import java.sql.PreparedStatement;
  9. import java.sql.ResultSet;
  10. import java.sql.SQLException;
  11. import java.util.ArrayList;
  12. import java.util.List;
  13. import java.util.Scanner;
  14. public class InsertIntoDB {
  15. //读取文本操作
  16. public static String[] writeToDat(String path) {
  17. File file = new File(path);
  18. List<String> list = new ArrayList<String>();
  19. String []strings = null;
  20. try {
  21. BufferedReader bw = new BufferedReader(new FileReader(file));
  22. String line = null;
  23. //因为不知道有几行数据,所以先存入list集合中
  24. while((line = bw.readLine()) != null){
  25. list.add(line);
  26. }
  27. bw.close();
  28. } catch (IOException e) {
  29. e.printStackTrace();
  30. }
  31. //确定数组长度
  32. strings = new String[list.size()];
  33. for(int i=0;i<list.size();i++){
  34. String s = (String) list.get(i);
  35. strings[i] = s;
  36. }
  37. return strings;
  38. }
  39. //连接数据库
  40. public static Connection getConnection(String data,String user,String pwd){
  41. Connection conn = null;
  42. try {
  43. Class.forName("com.mysql.jdbc.Driver");
  44. conn =
    DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/"+ data
    +"?characterEncoding=UTF-8",user , pwd);
  45. } catch (Exception e) {
  46. e.printStackTrace();
  47. }
  48. return conn;
  49. }
  50. //插入数据库,只能为一个字段
  51. public static boolean insertInto(String data,String table,String field,String user,String pwd,String []str){
  52. try {
  53. Connection conn = getConnection(data,user,pwd);
  54. conn.setAutoCommit(false);
  55. String sql = "INSERT INTO"+ table + "("+ field +") VALUES (?);";
  56. PreparedStatement pstmt = conn.prepareStatement(sql);
  57. for (int i = 0; i < str.length; i++) {
  58. pstmt.setString(1, str[i]);
  59. pstmt.executeUpdate();
  60. //                        conn.commit();
  61. }
  62. conn.commit();
  63. return true;
  64. } catch (SQLException e) {
  65. // TODO Auto-generated catch block
  66. e.printStackTrace();
  67. return false;
  68. }
  69. }
  70. public static String[] query(String data,String table,String field,String user,String pwd){
  71. try {
  72. String []str = null;
  73. int i = 0;
  74. Connection conn = getConnection(data,user,pwd);
  75. String sql = "select "+ field +" from" + table +";" ;
  76. PreparedStatement pstmt = conn.prepareStatement(sql);
  77. ResultSet rs = pstmt.executeQuery();
  78. while (rs.next()) {
  79. str[i] = rs.getString(field);
  80. i++;
  81. }
  82. return str;
  83. } catch (SQLException e) {
  84. // TODO Auto-generated catch block
  85. e.printStackTrace();
  86. return null;
  87. }
  88. }
  89. public  static void main(String[] args){
  90. String []str2 = null;
  91. String []str = null;
  92. String []str3 = null;
  93. boolean flage1 = true;
  94. boolean flage2 = true;
  95. boolean flage3 = true;
  96. System.out.println("请输入目标文件绝对路径:");
  97. Scanner sc = new Scanner(System.in);
  98. String path = sc.next();
  99. while(flage3){
  100. if (path!=null&&!path.equals("")) {
  101. flage3 = false;
  102. str = writeToDat(path);
  103. }else {
  104. System.out.println("输入不能为空");
  105. }
  106. }
  107. System.out.println("请输入所需连接的数据库名,表名,字段名(只能为一个),用户名,密码,用“#”隔开:");
  108. String strA = sc.next();
  109. while(flage1){
  110. if (strA!=null&&!strA.equals("")) {
  111. flage1 = false;
  112. while(flage2){
  113. if (strA.indexOf("#")>=0) {
  114. flage2 = false;
  115. str2 = strA.split("#");
  116. }else {
  117. System.out.println("您输入的格式有错,请重新输入");
  118. }
  119. }
  120. }else {
  121. System.out.println("输入不能为空");
  122. }
  123. }
  124. boolean b = insertInto(str2[0], str2[1], str2[2], str2[3], str2[4],str);
  125. if(b){
  126. System.out.println("插入成功!");
  127. }else {
  128. System.out.println("插入失败!");
  129. }
  130. str3 = query(str2[0], str2[1], str2[2], str2[3], str2[4]);
  131. for (int i = 0; i < str3.length; i++) {
  132. System.out.println(str3[i]);
  133. }
  134. }
  135. }

复制代码

时间: 2024-10-25 17:36:38

java读取本地txt文件并插入数据库的相关文章

sql 读取本地txt文件批量插入数据库

--导入 INSERT INTO [netmonsdb].[dbo].[keywordlist]([keyword]) SELECT * FROM OPENROWSET( BULK 'D:/xmsys/dd/dd.txt', FORMATFILE='d:/BCPFORMAT.xml' --, FIRSTROW=2 ) AS T; <?xml version="1.0"?> <BCPFORMAT xmlns="http://schemas.microsoft.

java读取本地text文件

//按字节读取 public static void readByBytes(String url) { File file = new File(url); InputStream in = null; try { in = new FileInputStream(file); int temp; while ((temp = in.read()) != -1) { System.out.println(temp); } } catch (FileNotFoundException e) {

js读取本地txt文件中的json数据

list.txt内容 [ {"optionKey":"1", "optionValue":"Canon in D"}, {"optionKey":"2", "optionValue":"Wind Song"}, {"optionKey":"3", "optionValue":"W

Java基础-输入输出-2.编写IoDemo.java的Java应用程序,程序完成的功能是:首先读取text.txt文件内容,再通过键盘输入文件的名称为iodemo.txt,把text.txt的内容存入iodemo.txt

2.编写IoDemo.java的Java应用程序,程序完成的功能是:首先读取text.txt文件内容,再通过键盘输入文件的名称为iodemo.txt,把text.txt的内容存入iodemo.txt package Test03; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import jav

【Kettle】数据整合之FTP下载+本地照片文件导入Oracle数据库

一.数据整合业务场景     1.1 背景 因GA某系统进行调整,导致原先从该系统备份数据库获取的相应数据资源无法正常获取,后续的数据统一由GA某系统每日将前一日的ZTRY照片数据压缩后上传到指定的FTP服务器上,需要从该FTP上下载下来,解压后将JPEG照片数据解析加载进入数据库.     1.2 目标 需要建立作业可以定时从FTP下载服务器将ZIP文件下载到本地指定文件夹,将ZIP文件解压后,获得JPEG格式照片,通过Kettle转换将照片进行解析,同时按照一定的规则将照片的名字等信息解析拼

UWP 读取本地XML文件

读取本地XML文件时要将xxx.xml文件的“生成操作”改为“嵌入的资源”会比较好,在手机上运行的话需要改为“内容” <?xml version="1.0" encoding="utf-8"?> <DataSet xmlns="http://WebXml.com.cn/"> <diffgr:diffgram xmlns:msdata="urn:schemas-microsoft-com:xml-msdata

AJAX传输本地txt文件内容

写一个按钮,点击后在指定的div里显示本地txt文件内容 在本地新建一个test.txt,里面随便写点内容就好. 1 <!DOCTYPE html> 2 <html> 3 <head> 4 <meta charset="utf-8" /> 5 </head> 6 <body> 7 <input type="button" id="btn_test" value=&quo

FileReader读取中文txt文件编码丢失问题(乱码)(转)

有一个UTF-8编码的文本文件,用FileReader读取到一个字符串,然后转换字符集:str=new String(str.getBytes(),"UTF-8");结果大部分中文显示正常,但最后仍有部分汉字显示为问号! public static List<String> getLines(String fileName){ List<String> lines=new ArrayList<String>(); try { BufferedRead

Python读取中文txt文件错误:UnicodeEncodeError: &#39;gbk&#39; codec can&#39;t encode character

1 with open(file,'r') as f: 2 line=f.readline() 3 i=1 4 while line: 5 line=line.decode('utf-8') 6 print str(i)+": "+line7 line=f.readline() 8 i=i+1 用以上代码读取一个包含中文的txt文件时,在正确地读取并打印了六百多行之后,print str(i)+": "+line这一行报错: UnicodeEncodeError: