package com.kevin.mysql;
/*
* mysql 插入blog的例子
*
*/
import java.io.*;
import java.sql.*;
public class DBTest {
public static void main(String[] args) {
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=GBK";
String user = "root";
String password = "";
try {
Class.forName(driver);
Connection conn = DriverManager.getConnection(url, user, password);
File file = new File("./laurapausini.jpg");
int length = (int) file.length();
InputStream fin = new FileInputStream(file);
PreparedStatement pstmt = conn.prepareStatement(
"INSERT INTO files(description,filecontent) VALUES(?, ?)");
pstmt.setString(1, "Logo");
pstmt.setBinaryStream (2, fin, length);
pstmt.executeUpdate();
pstmt.clearParameters();
pstmt.close();
fin.close();
/*
* 读取blob输出到文件
*/
Statement stmt = conn.createStatement();
ResultSet result = stmt.executeQuery("SELECT * FROM files");
result.next();
String description = result.getString(1);
Blob blob = result.getBlob(2);
System.out.println("描述:" + description);
FileOutputStream fout = new FileOutputStream("./laurapausini2.jpg");
fout.write(blob.getBytes(1, (int)blob.length()));
fout.flush();
fout.close();
stmt.close();
conn.close();
}
catch(ClassNotFoundException e) {
System.out.println("找不到驱动");
e.printStackTrace();
}
catch(SQLException e) {
e.printStackTrace();
}
catch(IOException e) {
e.printStackTrace();
}
}
}
|