simplewriteblob.java

JDBC描述详解JDBC描述详解JDBC描述详解JDBC描述详解

//package com.jdbclab;
import java.sql.*;
import java.io.*;
public class SimpleWriteBlob
{
	public static void main(String[] args){
	  String filename = args[0];
	  Connection con = null;
	  PreparedStatement ps = null;
	  ResultSet rs = null;
	  String sql = "";
	  try{
	    con = JdbcUtil.getConnection();
		con.setAutoCommit(false);
		File file = new File(filename);
		int len = (int) file.length();
		InputStream fis = new FileInputStream(file);
	    sql = "insert into changzhou_blob "+
		   "values(?,?,?)";
        ps = con.prepareStatement(sql);
		ps.setInt(1,4);
		ps.setString(2,filename);
		ps.setBinaryStream(3,fis, len);
		ps.executeUpdate();
		fis.close();
		con.commit();
	  }catch(Exception e){
	    e.printStackTrace();
		if(con!=null){
		  try{
		    con.rollback();
		  }catch(Exception ex){
		    ex.printStackTrace();
		  }
		}
	  }finally{
	    JdbcUtil.release(null,ps,con);
	  }
	}
}