java JDBC-将字符串、文件内容传入到数据库Clob文本大对象字段

r囧r小猫 2021-07-25 00:28 351阅读 0赞

public class Demo10 { 
    	public static void main(String[] args) throws FileNotFoundException { 
    		Connection conn=null;
    		PreparedStatement ps=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,myinfos) values(?,?)");
    			ps.setString(1, "web");
    			
    			//输入大文本对象，setClob第二个参数为输入流
    			ps.setClob(2,new FileReader(new File("d:/a.txt")));
    			
    			int lines=ps.executeUpdate();
    			System.out.println(lines);
    			//将字符串输入到数据库
    			ps.setClob(2,new BufferedReader(new InputStreamReader(new ByteArrayInputStream("adwdadw".getBytes()))));
    			ps.executeUpdate();
    			
    			ps=conn.prepareStatement("select * from t_user where id =?");
    			ps.setObject(1,"21021");
    			ResultSet set=ps.executeQuery();
    			
    			while(set.next())
    			{ 
    				Clob c=set.getClob("myinfos");
    				Reader r=c.getCharacterStream();
    				int len=-1;
    				while((len=r.read())!=-1)
    				{ 
    					System.out.print((char)len);
    				}
    				
    			}
    			
    		} catch (ClassNotFoundException e) { 
    			e.printStackTrace();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		} catch (IOException e) { 
    			e.printStackTrace();
    		}finally { 
    			
    			try { 
    				if(null!=ps)
    				{ 
    					ps.close();
    				}
    			}catch(SQLException e)
    			{ 
    				e.printStackTrace();
    			}
    			try { 
    				if(null!=conn)
    				{ 
    					conn.close();
    				}
    			}catch(SQLException e)
    			{ 
    				e.printStackTrace();
    			}
    		}
    		
    	}
    }