//假设这里建立的数据库位use,而建立的表位luser
import java.io.*;
import java.sql.*;
public class DBB{
private static String driver ="com.mysql.jdbc.driver";
private static String url ="jdbc:mysql://localhost:3306/use";
private static String user="root";
private static String pass="admin";
public static void main(String[]args){
Connection con= null;
PreparedStatement sta= null;
ResultSet res= null;
try{
//获取数据源
//假设就是从d盘中读取的一张照片；
File file= new File("d:" + File.separator + "photo.jpg");
int length= (int)file.length();
InputStream input = new FileInputStream(file);
//加载mysql驱动
Class.forName(driver);
//取得链接对象
con= DriverManager.getConnection(url,user,pass);
//取得操作对象
sta= con.prepareStatement("insert into luser values(?,?,?);");
//加载数据
sta.setInt(1,110);
sta.setString(2,"namefile");
sta.setBinaryStream(3,input ,length);
sta.executeUpdate();
sta.clearParameters();
input.close();//释放资源；
}catch(SQLException e){
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();
}catch(ClassNotFoundException e){
e.printStackTrace();
}
finally{
if(con!=null){
try{
con.close();
}catch(SQLException e){ //(_)%^&**(_)(&*)(*#%$%^&*(()__)(((
e.printStackTrace();
}
}
}
Statement stat= null;
try{
//数据的取得
stat= con.createStatement();
stat.executeQuery("select* from luser;");
res.next();
String filename= res.getString(2);
Blob blob= res.getBlob(3);
//把获得的数据写到指定的文件中
FileOutputStream out= new FileOutputStream("d:" + File.separator+ "dong" +".bak");
out.write(blob.getBytes(1,(int)blob.length()));
out.flush();//把内存中的东西刷出来
out.close();//释放资源
}catch(SQLException e){
e.printStackTrace();
}
catch(IOException e){
e.printStackTrace();
}
finally{
if(stat!= null){
try{
stat.close();
}catch(SQLException e){
e.printStackTrace();
}
}
if(con!=null){
try{
con.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
}
}