一、用java向MySQL中的表插入1億條數據的方法
1、使用MySQL的存儲過程
MySQL中的存儲過程是一組預定義好的SQL語句,可以像函數一樣進行調用。使用存儲過程可以將數據的插入操作從Java程序中移動到MySQL服務器上執行,從而提高了效率。
創建存儲過程的SQL語句如下:
CREATE PROCEDURE insert_data(IN count INT)BEGIN DECLARE i INT DEFAULT 0; WHILE i < count DO INSERT INTO table_name (column1, column2, …) VALUES (value1, value2, …); SET i = i + 1; END WHILE;END
其中,count為插入的總記錄數目,table_name為要插入數據的表名,column1、column2等為列名,value1、value2等為對應列的值。該存儲過程使用while循環語句將數據插入到指定的表中。
調用存儲過程的代碼如下:
CallableStatement cstmt = conn.prepareCall("{call insert_data(?)}");
cstmt.setInt(1, 100000000);
cstmt.execute();
使用CallableStatement接口調用存儲過程,并通過setInt方法設置參數count的值。最后,通過execute()方法執行存儲過程插入數據。
2、使用LOAD DATA INFILE
LOAD DATA INFILE是MySQL中用于導入數據的命令。使用該命令可以將數據文件快速地導入到MySQL數據庫中,比直接使用INSERT語句插入數據更有效率。
使用LOAD DATA INFILE的SQL語句如下:
LOAD DATA INFILE 'file_path' INTO TABLE table_name
FIELDS TERMINATED BY ',' (column1, column2, …);
其中,file_path為數據文件的路徑,table_name為要插入數據的表名,column1、column2等為列名。該命令可以使用FIELDS TERMINATED BY指定字段分隔符。
在Java程序中,可以使用Statement接口的executeUpdate方法執行LOAD DATA INFILE命令,如下所示:
Statement stmt = conn.createStatement();stmt.executeUpdate("LOAD DATA INFILE 'file_path' INTO TABLE table_name " + "FIELDS TERMINATED BY ',' (column1, column2, …)");
3、使用Java的JDBC調用addBatch()和executeBatch()方法
JDBC是Java Database Connectivity的縮寫,它是Java程序和數據庫之間的連接橋梁。使用JDBC可以通過Java程序直接訪問數據庫,并進行數據的增刪改查等操作。
使用Java的JDBC,可以通過PreparedStatement接口的addBatch()方法批量插入數據,并使用executeBatch()方法將多個SQL語句一次性提交給數據庫執行。
插入數據的代碼如下:
String sql = "INSERT INTO table_name (column1, column2, …) VALUES (?, ?, …)";PreparedStatement pstmt = conn.prepareStatement(sql);for (int i = 0; i < 100000000; i++) { pstmt.setInt(1, value1); pstmt.setString(2, value2); … pstmt.addBatch(); if (i % 1000 == 0) { pstmt.executeBatch(); }}pstmt.executeBatch();
其中,sql為要執行的SQL語句,column1、column2等為列名,value1、value2等為對應列的值。使用PreparedStatement接口的setXXX()方法設置SQL語句的參數值。通過for循環批量添加數據,并在每1000條數據后調用executeBatch()方法提交一次數據。最后,通過執行pstmt.executeBatch()方法提交剩余的數據。
二、MySQL插入數據
MySQL 表中使用 INSERT INTO SQL語句來插入數據。你可以通過 mysql> 命令提示窗口中向數據表中插入數據,或者通過PHP腳本來插入數據。
1、語法
以下為向MySQL數據表插入數據通用的?INSERT INTO?SQL語法:
INSERT INTO table_name ( field1, field2,...fieldN ) VALUES ( value1, value2,...valueN );
如果數據是字符型,必須使用單引號或者雙引號,如:”value”。
2、通過命令提示窗口插入數據
以下我們將使用 SQL INSERT INTO 語句向 MySQL 數據表 runoob_tbl 插入數據
實例:
以下實例中我們將向 runoob_tbl 表插入三條數據:
root@host# mysql -u root -p password;Enter password:*******mysql> use RUNOOB;Database changedmysql> INSERT INTO runoob_tbl -> (runoob_title, runoob_author, submission_date) -> VALUES -> ("學習 PHP", "教程", NOW());Query OK, 1 rows affected, 1 warnings (0.01 sec)mysql> INSERT INTO runoob_tbl -> (runoob_title, runoob_author, submission_date) -> VALUES -> ("學習 MySQL", "教程", NOW());Query OK, 1 rows affected, 1 warnings (0.01 sec)mysql> INSERT INTO runoob_tbl -> (runoob_title, runoob_author, submission_date) -> VALUES -> ("JAVA 教程", "RUNOOB.COM", '2016-05-06');Query OK, 1 rows affected (0.00 sec)mysql>
注意:使用箭頭標記 -> 不是 SQL 語句的一部分,它僅僅表示一個新行,如果一條SQL語句太長,我們可以通過回車鍵來創建一個新行來編寫 SQL 語句,SQL 語句的命令結束符為分號。
在以上實例中,我們并沒有提供 runoob_id 的數據,因為該字段我們在創建表的時候已經設置它為 AUTO_INCREMENT(自動增加) 屬性。 所以,該字段會自動遞增而不需要我們去設置。實例中 NOW() 是一個 MySQL 函數,該函數返回日期和時間。
3、使用PHP腳本插入數據
你可以使用PHP 的 mysqli_query() 函數來執行 SQL INSERT INTO命令來插入數據。該函數有兩個參數,在執行成功時返回 TRUE,否則返回 FALSE。
語法:
mysqli_query(connection,query,resultmode);
實例:
以下實例中程序接收用戶輸入的三個字段數據,并插入數據表中:
';// 設置編碼,防止中文亂碼mysqli_query($conn , "set names utf8"); $runoob_title = '學習 Python';$runoob_author = 'RUNOOB.COM';$submission_date = '2016-03-06'; $sql = "INSERT INTO runoob_tbl ". "(runoob_title,runoob_author, submission_date) ". "VALUES ". "('$runoob_title','$runoob_author','$submission_date')"; mysqli_select_db( $conn, 'RUNOOB' );$retval = mysqli_query( $conn, $sql );if(! $retval ){ die('無法插入數據: ' . mysqli_error($conn));}echo "數據插入成功\n";mysqli_close($conn);?>
對于含有中文的數據插入,需要添加 mysqli_query($conn , “set names utf8”); 語句。
延伸閱讀1:Java語言簡介
Java是Sun公司推出的能夠跨越多平臺的、可移植性較高的一種面向對象的編程語言,也是目前非常先進、特征最豐富、功能較早大的計算機語言。利用Java可以編寫桌面應用程序、Web應用程序、分布式系統應用程序、嵌入式系統應用程序等,從而使其成為應用較廣泛的開發語言。