java JDBC-将信息输入Blob二进制大对象字段

朴灿烈づ我的快乐病毒、 2021-07-24 15:22 268阅读 0赞

public class Demo10 {
    	public static void main(String[] args) throws FileNotFoundException {
    		Connection conn=null;
    		PreparedStatement ps=null;
    		ResultSet set=null;
    		InputStream is=null;
    		try {
    			Class.forName("com.mysql.jdbc.Driver");
    			conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","dyl123");
    			
    
    			ps=conn.prepareStatement("insert into t_user(username,headImag) values(?,?)");
    			ps.setString(1, "css");
    			//通过流来读取信息进入Blob字段
    			ps.setBlob(2,new FileInputStream("C:\\Users\\10853\\Desktop\\java statement接口.png"));
    
    			ps.execute();
    			
    			ps=conn.prepareStatement("select * from t_user where id =?");
    			ps.setInt(1, 201002);
    			
    			set=ps.executeQuery();
    			int len=-1;
    			while(set.next())
    			{
    				Blob b=set.getBlob("headImag");
    				//因为Blob是二进制流，所以不能有字符流Reader来读取
    				is=b.getBinaryStream();
    				while((len=is.read())!=-1)
    				{
    					System.out.println((char)len);
    				}
    			}
    
    			
    		} catch (ClassNotFoundException e) {
    			e.printStackTrace();
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}finally {
    			
    			try {
    				if(null!=r)
    				{
    					r.close();
    				}
    			}catch(IOException e)
    			{
    				e.printStackTrace();
    			}
    			try {
    				if(null!=set)
    				{
    					set.close();
    				}
    			}catch(SQLException e)
    			{
    				e.printStackTrace();
    			}
    			
    			try {
    				if(null!=ps)
    				{
    					ps.close();
    				}
    			}catch(SQLException e)
    			{
    				e.printStackTrace();
    			}
    			try {
    				if(null!=conn)
    				{
    					conn.close();
    				}
    			}catch(SQLException e)
    			{
    				e.printStackTrace();
    			}
    		}
    		
    	}
    }