劇多
首頁
資訊
體育
娛樂
汽車
投資
財經
軍事
科技
數碼
科學
遊戲
歷史
健康
政治
影視
旅遊
育兒
美食
時尚
房產
農業
社會
文化
教育
技術
美文
情感
故事
家居
職場
自然
闢謠
心理
攝影
漫畫
生活
其它
Club
Tips
熱門話題
搜尋
註冊
登入
首頁
>
Club
>
執爸KkIQ1093
2021-04-18 07:25
記事本中用sql語句寫好的資料怎麼匯入到MYSQL的對應表中?
17
回覆列表
1 # 兔子講Java
不知道你記事本中的資料的格式具體是什麼樣的?這邊我按我猜測的兩種格式給你舉個例子。
格式一
格式二
公用方法
獲取連線的方法如下,還有兩個就是關閉連線的方法就不貼圖了。
表結構
總結
import java.io.*;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;public class TestStudent { public static void insertOne() { Connection conn = getConn(); PreparedStatement pstmt = null; String filePath1 = "C:/Users/Edianzu/Desktop/cc/111.txt";int count = 0; try { BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath1), "gbk"));String sql; while ((sql = br.readLine()) != null) { pstmt = conn.prepareStatement(sql);pstmt.executeUpdate(); count++;} System.out.println("一共成功插入了" + count + "條資料"); } catch (Exception e) { e.printStackTrace(); } closePreparedStatement(pstmt); closeConn(conn); } public static void insertTwo() { Connection conn = getConn(); PreparedStatement pstmt = null; String filePath2 = "C:/Users/Edianzu/Desktop/cc/222.txt"; int count = 0; try { BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath2), "gbk"));String text; String sql = "insert into t_student(id,name) values(?,?)"; pstmt = conn.prepareStatement(sql); while ((text = br.readLine()) != null) {String[] textArr = text.split(",");pstmt.setInt(1, Integer.parseInt(textArr[0]));pstmt.setString(2, textArr[1]);pstmt.executeUpdate();count++; } System.out.println("一共成功插入了" + count + "條資料"); } catch (Exception e) {e.printStackTrace(); } closePreparedStatement(pstmt);closeConn(conn); } public static void main(String[] args) { // 格式一 insertOne(); // 格式二 // insertTwo(); } private static Connection getConn() { String driver = "com.mysql.cj.jdbc.Driver";String url = "jdbc:mysql://localhost:3306/test1?serverTimezone=UTC&useUnicode=true&characterEncoding=gbk&useSSL=false"; String username = "root"; String password = "admin";Connection conn = null; try { Class.forName(driver);conn = DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException | SQLException e) { e.printStackTrace(); } return conn; } private static void closePreparedStatement(PreparedStatement ps) { if (ps != null) { try { ps.close(); } catch (SQLException e) { e.printStackTrace(); } } } private static void closeConn(Connection conn) { if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }}
發表回復
相關內容
mysql用sql語句建立表和資料庫怎麼設定字元編碼'?
MYSQL表中新增欄位指定位置,SQL語句該怎麼寫?
excel中sql語句規則?
mysql資料庫資料能不能匯入到sql server中?
用SQL語句查詢資料庫中某一欄位下相同值的記錄方法?
sql語句怎麼新增一條記錄?
sql語句,同時查詢兩個表?
dbvisualizer怎樣格式化sql語句?
mysql匯入sql檔案命令匯入資料庫快不快?
sql查詢語句中的“UNIONALL”是什麼意思?
∧
中秋節和大豐收的關聯?
∨
什麼是小蘇打溫泉?
熱門排行
摸回來的螺洗乾淨能養多少天?
燃氣熱水器暗埋管需要多長?
手機屏幕起泡對手機屏幕有影響嗎?
權盟麥克風和魅鳥麥克風的區別?
少數民族預科的投檔線是怎麼規定的?
6歲小孩適合小天才哪個型號的?
電加熱爐溫度控制器怎麼調節?
4.2米廂車合法合規標準尺寸?
愛對人無價愛錯人一文不值的意思?
植物大戰僵尸2爆破手五階需要什麼?
不知道你記事本中的資料的格式具體是什麼樣的?這邊我按我猜測的兩種格式給你舉個例子。
格式一
格式二
公用方法
獲取連線的方法如下,還有兩個就是關閉連線的方法就不貼圖了。
表結構
總結
import java.io.*;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;public class TestStudent { public static void insertOne() { Connection conn = getConn(); PreparedStatement pstmt = null; String filePath1 = "C:/Users/Edianzu/Desktop/cc/111.txt";int count = 0; try { BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath1), "gbk"));String sql; while ((sql = br.readLine()) != null) { pstmt = conn.prepareStatement(sql);pstmt.executeUpdate(); count++;} System.out.println("一共成功插入了" + count + "條資料"); } catch (Exception e) { e.printStackTrace(); } closePreparedStatement(pstmt); closeConn(conn); } public static void insertTwo() { Connection conn = getConn(); PreparedStatement pstmt = null; String filePath2 = "C:/Users/Edianzu/Desktop/cc/222.txt"; int count = 0; try { BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(filePath2), "gbk"));String text; String sql = "insert into t_student(id,name) values(?,?)"; pstmt = conn.prepareStatement(sql); while ((text = br.readLine()) != null) {String[] textArr = text.split(",");pstmt.setInt(1, Integer.parseInt(textArr[0]));pstmt.setString(2, textArr[1]);pstmt.executeUpdate();count++; } System.out.println("一共成功插入了" + count + "條資料"); } catch (Exception e) {e.printStackTrace(); } closePreparedStatement(pstmt);closeConn(conn); } public static void main(String[] args) { // 格式一 insertOne(); // 格式二 // insertTwo(); } private static Connection getConn() { String driver = "com.mysql.cj.jdbc.Driver";String url = "jdbc:mysql://localhost:3306/test1?serverTimezone=UTC&useUnicode=true&characterEncoding=gbk&useSSL=false"; String username = "root"; String password = "admin";Connection conn = null; try { Class.forName(driver);conn = DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException | SQLException e) { e.printStackTrace(); } return conn; } private static void closePreparedStatement(PreparedStatement ps) { if (ps != null) { try { ps.close(); } catch (SQLException e) { e.printStackTrace(); } } } private static void closeConn(Connection conn) { if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }}