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

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

复制代码