Insert text file into MySQL
import? java.io.File;import? java.io.FileInputStream;
import? java.sql.Connection;
import? java.sql.DriverManager;
import? java.sql.PreparedStatement;
public?class? InsertTextFileToMySQL? {
?? public?static? Connection?getConnection ()? throws? Exception? {
???? String?driver?=? "org.gjt.mm.mysql.Driver" ;
???? String?url?=? "jdbc:mysql://localhost/databaseName" ;
???? String?username?=? "root" ;
???? String?password?=? "root" ;
???? Class .forName ( driver ) ;
???? Connection?conn?=?DriverManager.getConnection ( url,?username,?password ) ;
???? return? conn;
?? }
?? public?static? void? main ( String []? args ) throws? Exception? {
???? String?id?=? "001" ;
???? String?fileName?=? "fileName.txt" ;
????
???? FileInputStream?fis?=? null ;
???? PreparedStatement?pstmt?=? null ;
???? Connection?conn?=? null ;
???? try? {
?????? conn?=?getConnection () ;
?????? conn.setAutoCommit ( false ) ;
?????? File?file?=? new? File ( fileName ) ;
?????? fis?=? new? FileInputStream ( file ) ;
?????? pstmt?=?conn.prepareStatement ( "insert?into?DataFiles(id,?fileName,?fileBody)?values?(?,??,??)" ) ;
?????? pstmt.setString ( 1 ,?id ) ;
?????? pstmt.setString ( 2 ,?fileName ) ;
?????? pstmt.setAsciiStream ( 3 ,?fis,? ( int )? file.length ()) ;
?????? pstmt.executeUpdate () ;
?????? conn.commit () ;
???? }? catch? ( Exception?e )?{
?????? System.err.println ( "Error:?"? +?e.getMessage ()) ;
?????? e.printStackTrace () ;
???? }? finally? {
?????? pstmt.close () ;
?????? fis.close () ;
?????? conn.close () ;
???? }
?? }
}
posted on 2006-09-13 11:33 zhaofei1394 閱讀(660) 評論(0) 編輯 收藏 所屬分類: SQL Server