JDBC处理大数据

秒速五厘米 2022-05-21 05:43 143阅读 0赞

> 使用Mysql数据库也可以处理大数据，在实际开发中需要把大文本或者二进制数据保存到数据库中去。clob是用来存储大文本的,mysql数据库不支持。bclob用于存储二进制数据，例如：图像、声音、二进制文件等。
> 
> 对于Mysql的Text类型，可调用如下方法设置：
> 
> preparedStatment.setCharacterStatment(index,reader,length);
> 
> 对于MYSQL中的Text类型，可调用如下方法获取：
> 
>  reader = result.getCharacterStreate(i);
> 
> reader = result.getClob(i).getCharacterStream();
> 
> String s = result.getString();
> 
> 首先应在编译器src文件夹下创建一个text文档，用于存储数据，写进数据库。

![70][]

1.text实现写入的数据如下：

![70 1][]

> 然后编写代码进行写大数据到数据库。代码如下
> 
> 代码：
> 
> @Test  
> public void insert()\{  
> Connection connection = null;  
> PreparedStatement st = null;  
> ResultSet rs = null;  
> try \{  
> connection = JDBCUtil.getConnection();  
> String sql = "insert into testclob(id,resume) values(?,?)";  
> st =(PreparedStatement) connection.prepareStatement(sql);  
> st.setString(1,"1");  
> File file = new File("src/1.text");  
> FileReader reader = new FileReader(file);  
> st.setCharacterStream(2, reader, (int)file.length());  
> int num = st.executeUpdate();  
> if(num > 0)\{  
> System.out.println("插入成功！");  
> \}  
> \} catch (Exception e) \{  
> e.printStackTrace();  
> \}finally \{  
> JDBCUtil.close(rs, st, connection);  
> \}
> 
> \}
> 
> 查询数据库中的表，是否成功插入到数据库中。
> 
> ![70 2][]
> 
> 写大文本数据到数据库结束，在从数据库中读取大文本数据。到计算机的D盘路径下。
> 
> 代码如下：
> 
> @Test  
> public void read()\{  
> Connection connection = null;  
> PreparedStatement st = null;  
> ResultSet rs = null;  
> try \{  
> connection = JDBCUtil.getConnection();  
> String sql = "select id,resume from testclob where id = '1' ";  
> st = (PreparedStatement)connection.prepareStatement(sql);  
> rs = st.executeQuery();  
> if(rs.next())\{  
> //String str = rs.getString("reume"); 适用于小文本  
> Reader reader = rs.getCharacterStream("resume");  
> FileWriter writer = new FileWriter("D:\\\\testclob.text");    
> try\{  
> int len = 0;  
> char buffer\[\] = new char\[1024\];  
> while((len = reader.read(buffer)) > 0)\{  
> writer.write(buffer,0,len);  
> \}  
> \}finally\{  
> if(reader!=null)\{  
>     reader.close();  
> \}  
> writer.close();  
> \}  
> \}  
>   
> \} catch (Exception e) \{  
> e.printStackTrace();  
> \}finally \{  
> JDBCUtil.close(rs, st, connection);  
> \}
> 
> \}
> 
>  
> 
> 运行成功，到D盘查看生成的text文本。
> 
> 文本内容如下：

![70 3][]

![70 4][]

[70]: /images/20220521/def57065a32d4692b3b13290d9cef3f5.png
[70 1]: /images/20220521/f9f4b18e4c514ef58758a8517df3d877.png
[70 2]: /images/20220521/df3e40fd2b7445418d1d33988c10604b.png
[70 3]: /images/20220521/77916c1537d94ade93bf8a80c642fb71.png
[70 4]: /images/20220521/e3b5d308232c4bb486f0b0b33a7cee1e.png