问题描述：向数据库中插入大文本数据，以及从数据库中读取大文本
        问题是数据插入后用cmd 查询数据库，查询出来的结果只有几行数据，但是我从数据库中读取打印到控制台又是对的！
问题2插入二进制的大数据比如图片：插入大数据之后，在从数据库中拷贝出来的数据比原始数据大了几十倍而且图片还打不开！
代码如下：

1. package cn.jdbc;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.BufferedReader;
   
6. import java.io.File;
   
7. import java.io.FileInputStream;
   
8. import java.io.FileOutputStream;
   
9. import java.io.FileReader;
   
10. import java.io.InputStream;
    
11. import java.io.OutputStream;
    
12. import java.io.Reader;
    
13. import java.sql.Connection;
    
14. import java.sql.PreparedStatement;
    
15. import java.sql.ResultSet;
    
16. import java.sql.SQLException;
    
17. import java.sql.Statement;
    
18. 
    
19. import oracle.sql.BLOB;
    
20. 
    
21. import cn.utils.JdbcUtil;
    
22. 
    
23. public class JdbcAccessBigData {
    
24.         public static void main(String[] args) {
    
25.                 //insertAndReadBigText();//代表大文本数据
    
26.                 insertAndCopyPicture();//代表大型的二进制码数据，图片，视频等       
    
27.         }
    
28.         @SuppressWarnings("deprecation")
    
29.         private static void insertAndCopyPicture() {
    
30.                 Connection conn=JdbcUtil.getConnection();
    
31.                 Statement st=null;
    
32.                 PreparedStatement ps=null;
    
33.                 ResultSet rs=null;
    
34.                 String sql="insert into bigPicture values(?)";
    
35.                 String sql2="select picture from bigPicture";
    
36.                        
    
37.                 try {
    
38.                         //将数据插入到数据库，这种方式只适合MySQL,不适合Oracle
    
39.                         /*ps=conn.prepareStatement(sql);
    
40.                         File file=new File("src/cn/ojdbc/wusi.jpg");
    
41.                         InputStream ins=new BufferedInputStream(new FileInputStream(file));
    
42.                         ps.setBinaryStream(1, ins);//2进制字节流
    
43.                         //ps.setBlob(1, ins);
    
44.                         ps.execute();
    
45.                         ins.close();*/
    
46.                         /**Oracle 版本，从java中向数据库中插入图片 ：*/
    
47.                         st=conn.createStatement();
    
48.                         conn.setAutoCommit(false);
    
49.                         st.executeQuery("insert into bigPicture values(empty_blob())");
    
50.                         rs=st.executeQuery("select picture from bigPicture for update");
    
51.                         if(rs.next()){
    
52.                                 //注意这里的BLOB对象时oracle里面的不是java中的
    
53.                                 BLOB blob=(BLOB) rs.getBlob("picture");
    
54.                                 @SuppressWarnings("unused")
    
55.                                 OutputStream out=blob.getBinaryOutputStream();
    
56.                                
    
57.                                 File file=new File("src/cn/ojdbc/wusi.jpg");
    
58.                                 InputStream ins=new BufferedInputStream(new FileInputStream(file));
    
59.                                 byte[] buf=new byte[1024];
    
60.                                 int n=0;
    
61.                                 while((n=ins.read(buf))!=-1){
    
62.                                         // 下面这样写报错--java.io.IOException: ORA-22920: 未锁定含有 LOB 值的行
    
63.                                         //是因为select中没有写 for update
    
64.                                         out.write(buf, 0, n);
    
65.                                 }
    
66.                                 out.flush();
    
67.                                 out.close();
    
68.                                 ins.close();
    
69.                         }
    
70.                        
    
71.                         //从数据库中读取数据显示,貌似对于这样的数据好像不行。只能拷贝？
    
72.                         //这里出现的问题 从数据库中拷贝出来的图片大小放大了n倍，而且图片打不开？
    
73.                         st=conn.createStatement();
    
74.                         rs=st.executeQuery(sql2);
    
75.                         if(rs.next()){
    
76.                                 InputStream ins2=rs.getBinaryStream(1);
    
77.                                 OutputStream out=new BufferedOutputStream(new FileOutputStream("src/cn/ojdbc/wusi2.jpg"));
    
78.                                 byte[] buf=new byte[1024];
    
79.                                 int n=0;
    
80.                                 while((n=ins2.read())!=-1){
    
81.                                         out.write(buf,0,n);
    
82.                                         out.flush();
    
83.                                 }
    
84.                                 out.close();
    
85.                                 ins2.close();
    
86.                         }
    
87.                 } catch (Exception e) {
    
88.                         throw new RuntimeException(e);
    
89.                 }finally{
    
90.                         JdbcUtil.freeSource(rs, ps, conn);
    
91.                 }
    
92.                
    
93.         }
    
94.         //向数据库中插入大文本数据，以及从数据库中读取大文本
    
95.         //这里的问题是用cmd 查询数据库，查询出来的结果不对，但是我从数据库中读取打印又是对的？？？
    
96.         private static void insertAndReadBigText() {
    
97.                 Connection conn=JdbcUtil.getConnection();
    
98.                 PreparedStatement ps=null;
    
99.                 Statement st=null;
    
100.                 ResultSet rs=null;
     
101.                 String sql="insert into bigText values(?)";
     
102.                 String sql2="select * from bigText";
     
103.                 try {
     
104.                         //向数据库中插入大文本数据
     
105.                         ps=conn.prepareStatement(sql);
     
106.                         File file=new File("src/cn/utils/JdbcUtils.java");
     
107.                         Reader reader=new BufferedReader(new FileReader(file));
     
108.                         //将大文本转换成字符流，存放到数据库的字段中
     
109.                         ps.setCharacterStream(1,reader,file.length());
     
110.                         ps.execute();
     
111.                         reader.close();//关闭资源！！！
     
112.                        
     
113.                         //读取数据库中的大文本
     
114.                         st=conn.createStatement();
     
115.                         rs=st.executeQuery(sql2);
     
116.                         if(rs.next()){
     
117.                                 //将大文本字段转换成字符流
     
118.                                 BufferedReader br=new BufferedReader(rs.getCharacterStream("bigTxt"));
     
119.                                 int n=0;
     
120.                                 while(br.read()!=-1){
     
121.                                         System.out.println(br.readLine());
     
122.                                 }
     
123.                                 br.close();//关闭资源
     
124.                         }
     
125.                 } catch (Exception e) {
     
126.                         e.printStackTrace();
     
127.                         throw new RuntimeException(e);
     
128.                 }finally{
     
129.                         JdbcUtil.freeSource(rs, ps, conn);
     
130.                 }
     
131.         }
     
132. 
     
133. }
     

复制代码

问题描述：向数据库中插入大文本数据，以及从数据库中读取大文本
        问题是数据插入后用cmd 查询数据库，查询出来的结果只有几行数据，但是我从数据库中读取打印到控制台又是对的！
问题2插入二进制的大数据比如图片：插入大数据之后，在从数据库中拷贝出来的数据比原始数据大了几十倍而且图片还打不开！
代码如下：

1. package cn.jdbc;
   
2. 
   
3. import java.io.BufferedInputStream;
   
4. import java.io.BufferedOutputStream;
   
5. import java.io.BufferedReader;
   
6. import java.io.File;
   
7. import java.io.FileInputStream;
   
8. import java.io.FileOutputStream;
   
9. import java.io.FileReader;
   
10. import java.io.InputStream;
    
11. import java.io.OutputStream;
    
12. import java.io.Reader;
    
13. import java.sql.Connection;
    
14. import java.sql.PreparedStatement;
    
15. import java.sql.ResultSet;
    
16. import java.sql.SQLException;
    
17. import java.sql.Statement;
    
18. 
    
19. import oracle.sql.BLOB;
    
20. 
    
21. import cn.utils.JdbcUtil;
    
22. 
    
23. public class JdbcAccessBigData {
    
24.         public static void main(String[] args) {
    
25.                 //insertAndReadBigText();//代表大文本数据
    
26.                 insertAndCopyPicture();//代表大型的二进制码数据，图片，视频等       
    
27.         }
    
28.         @SuppressWarnings("deprecation")
    
29.         private static void insertAndCopyPicture() {
    
30.                 Connection conn=JdbcUtil.getConnection();
    
31.                 Statement st=null;
    
32.                 PreparedStatement ps=null;
    
33.                 ResultSet rs=null;
    
34.                 String sql="insert into bigPicture values(?)";
    
35.                 String sql2="select picture from bigPicture";
    
36.                        
    
37.                 try {
    
38.                         //将数据插入到数据库，这种方式只适合MySQL,不适合Oracle
    
39.                         /*ps=conn.prepareStatement(sql);
    
40.                         File file=new File("src/cn/ojdbc/wusi.jpg");
    
41.                         InputStream ins=new BufferedInputStream(new FileInputStream(file));
    
42.                         ps.setBinaryStream(1, ins);//2进制字节流
    
43.                         //ps.setBlob(1, ins);
    
44.                         ps.execute();
    
45.                         ins.close();*/
    
46.                         /**Oracle 版本，从java中向数据库中插入图片 ：*/
    
47.                         st=conn.createStatement();
    
48.                         conn.setAutoCommit(false);
    
49.                         st.executeQuery("insert into bigPicture values(empty_blob())");
    
50.                         rs=st.executeQuery("select picture from bigPicture for update");
    
51.                         if(rs.next()){
    
52.                                 //注意这里的BLOB对象时oracle里面的不是java中的
    
53.                                 BLOB blob=(BLOB) rs.getBlob("picture");
    
54.                                 @SuppressWarnings("unused")
    
55.                                 OutputStream out=blob.getBinaryOutputStream();
    
56.                                
    
57.                                 File file=new File("src/cn/ojdbc/wusi.jpg");
    
58.                                 InputStream ins=new BufferedInputStream(new FileInputStream(file));
    
59.                                 byte[] buf=new byte[1024];
    
60.                                 int n=0;
    
61.                                 while((n=ins.read(buf))!=-1){
    
62.                                         // 下面这样写报错--java.io.IOException: ORA-22920: 未锁定含有 LOB 值的行
    
63.                                         //是因为select中没有写 for update
    
64.                                         out.write(buf, 0, n);
    
65.                                 }
    
66.                                 out.flush();
    
67.                                 out.close();
    
68.                                 ins.close();
    
69.                         }
    
70.                        
    
71.                         //从数据库中读取数据显示,貌似对于这样的数据好像不行。只能拷贝？
    
72.                         //这里出现的问题 从数据库中拷贝出来的图片大小放大了n倍，而且图片打不开？
    
73.                         st=conn.createStatement();
    
74.                         rs=st.executeQuery(sql2);
    
75.                         if(rs.next()){
    
76.                                 InputStream ins2=rs.getBinaryStream(1);
    
77.                                 OutputStream out=new BufferedOutputStream(new FileOutputStream("src/cn/ojdbc/wusi2.jpg"));
    
78.                                 byte[] buf=new byte[1024];
    
79.                                 int n=0;
    
80.                                 while((n=ins2.read())!=-1){
    
81.                                         out.write(buf,0,n);
    
82.                                         out.flush();
    
83.                                 }
    
84.                                 out.close();
    
85.                                 ins2.close();
    
86.                         }
    
87.                 } catch (Exception e) {
    
88.                         throw new RuntimeException(e);
    
89.                 }finally{
    
90.                         JdbcUtil.freeSource(rs, ps, conn);
    
91.                 }
    
92.                
    
93.         }
    
94.         //向数据库中插入大文本数据，以及从数据库中读取大文本
    
95.         //这里的问题是用cmd 查询数据库，查询出来的结果不对，但是我从数据库中读取打印又是对的？？？
    
96.         private static void insertAndReadBigText() {
    
97.                 Connection conn=JdbcUtil.getConnection();
    
98.                 PreparedStatement ps=null;
    
99.                 Statement st=null;
    
100.                 ResultSet rs=null;
     
101.                 String sql="insert into bigText values(?)";
     
102.                 String sql2="select * from bigText";
     
103.                 try {
     
104.                         //向数据库中插入大文本数据
     
105.                         ps=conn.prepareStatement(sql);
     
106.                         File file=new File("src/cn/utils/JdbcUtils.java");
     
107.                         Reader reader=new BufferedReader(new FileReader(file));
     
108.                         //将大文本转换成字符流，存放到数据库的字段中
     
109.                         ps.setCharacterStream(1,reader,file.length());
     
110.                         ps.execute();
     
111.                         reader.close();//关闭资源！！！
     
112.                        
     
113.                         //读取数据库中的大文本
     
114.                         st=conn.createStatement();
     
115.                         rs=st.executeQuery(sql2);
     
116.                         if(rs.next()){
     
117.                                 //将大文本字段转换成字符流
     
118.                                 BufferedReader br=new BufferedReader(rs.getCharacterStream("bigTxt"));
     
119.                                 int n=0;
     
120.                                 while(br.read()!=-1){
     
121.                                         System.out.println(br.readLine());
     
122.                                 }
     
123.                                 br.close();//关闭资源
     
124.                         }
     
125.                 } catch (Exception e) {
     
126.                         e.printStackTrace();
     
127.                         throw new RuntimeException(e);
     
128.                 }finally{
     
129.                         JdbcUtil.freeSource(rs, ps, conn);
     
130.                 }
     
131.         }
     
132. 
     
133. }
     

复制代码