处理大数据对象1 clob

处理大数据对象（1）—处理CLOB数据赵翔宇大对象处理主要指的是CLOB和BLOB两种类型的字段，在CLOB中可以存储海量文字，例如，存储一部《三国演义》或者是《红楼梦》等。在BLOB中可以存储二进制数据，如图片、电影等等，如果在程序中要想处理这样的大对象操作，则必须使用PreparedStatement完成，所有的内容要通过IO流的方式从大文本字段中保存和读取。PreparedStatement提供了如下方法，专门用于写入大对象数据大对象数据设置到数据库中后，在查询时就需要使用ResultSet将其读取进来，在ResultSet中提供了如下的方法可以读取出大对象数据以上方法实际分为两组，Clob和AsciiStream一般都返回大文本，而Blob和BinaryStream一般都返回二进制数据。下面分别来看这些方法的操作，而Clob和Blob也将在操作时为大家介绍。处理CLOB数据CLOB表示大文本数据，在MySQL中提供了LONGTEXT表示大文本数据，此字段的最大保存数据量为4G。例如，下面有如下的数据库创建脚本：DROPTABLEuserclob;CREATETABLEuserclob( id INT AUTO_INCREMENTPRIMARYKEY, name VARCHAR(30) NOTNULL, note LONGTEXT);下面向此表中插入数据，其中对于note内容，使用如下图所示的文本表示。此文本大小是31KB保存在d盘中，文件名称是xlh.txt实例：写入大文本数据publicclassInsertDemo{ //定义数据库驱动地址

publicstaticfinalStringDBDRIVER="org.gjt.mm.mysql.Driver"; //定义数据库链接地址

publicstaticfinalStringDBURL="jdbc:mysql://localhost:3306/zxy"; //定义数据库连接用户名

publicstaticfinalStringDBUSER="root"; //定义数据库连接密码

publicstaticfinalStringDBPASS="mysqladmin"; publicstaticvoidmain(String[]args){ Connectioncon=null; PreparedStatementpstmt=null; InputStreaminput=null; Stringname="赵翔宇"; Stringsql="INSERTINTOuserclob(name,note)VALUES(?,?)"; try{ Class.forName(DBDRIVER); con=DriverManager.getConnection(DBURL,DBUSER,DBPASS); pstmt=con.prepareStatement(sql); Filef=newFile("d:"+File.separator+"xlh.txt"); input=newFileInputStream(f);

pstmt.setString(1,name); pstmt.setAsciiStream(2,input,(int)f.length()); pstmt.executeUpdate(); pstmt.close(); con.close(); }catch(ClassNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(FileNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } }}因为内容保存在文件中，所以使用FileInputStream类将文本文件读取进来，之后直接通过PreparedStatement对象将其写入到对应的大文本字段中。写入完成之后，下面直接使用ResultSet将其读取进来，因为写入时是按照输入流的方式写入的，所以此时也需要按照输入流的方式读取进来。实例：读取大文本字段publicclassInsertDemo{ //定义数据库驱动地址

publicstaticfinalStringDBDRIVER="org.gjt.mm.mysql.Driver"; //定义数据库链接地址

publicstaticfinalStringDBURL="jdbc:mysql://localhost:3306/zxy"; //定义数据库连接用户名

publicstaticfinalStringDBUSER="root"; //定义数据库连接密码

publicstaticfinalStringDBPASS="mysqladmin"; publicstaticvoidmain(String[]args){ Connectioncon=null; PreparedStatementpstmt=null; InputStreaminput=null; ResultSetrs=null; intid=1; Stringsql="SELECTname,noteFROMuserclobWHEREid=?"; try{ Class.forName(DBDRIVER); con=DriverManager.getConnection(DBURL,DBUSER,DBPASS); pstmt=con.prepareStatement(sql); pstmt.setInt(1,id);

rs=pstmt.executeQuery(); if(rs.next()){ Stringname=rs.getString(1); StringBuffernote=newStringBuffer(); System.out.println("姓名:"+name); input=rs.getAsciiStream(2); Scannerscan=newScanner(input); scan.useDelimiter("\n"); while(scan.hasNext()){ note.append(scan.next()).append("\n"); } System.out.println("内容:"+note.toString()); input.close(); pstmt.close(); con.close(); } }catch(ClassNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }

}}程序运行结果（部分）:姓名:赵翔宇内容:石村，位于苍莽山脉中，四周高峰大壑，茫茫群山巍峨。清晨，朝霞灿灿，仿若碎金一般洒落，沐浴在人身上暖洋洋。一群孩子，从四五岁到十几岁不等，能有数十人，在村前的空地上迎……………….以上程序中，为了操作方便，使用了Scanner类接收全部的输入内容。由于在文本保存时存在换行，所以使用“\n”作为分隔符，之后通过循环的方式不断的把内容读取出来并将内容保存在StringBuffer中。以上的做法是将发文本数据内容直接通过ResultSet读取进来，当然也可以使用ResultSet中提供的getClob()方法，将全部的内容变为Clob对象的内容。直接使用Clob可以方便的读取大文本的数据，也可以对这些文本数据进行一些简单的操作，如截取指定长度的文本等。Clob的常用方法如下所示：实例：使用Clob读取内容publicclassInsertDemo{ //定义数据库驱动地址

publicstaticfinalStringDBDRIVER="org.gjt.mm.mysql.Driver"; //定义数据库链接地址

publicstaticfinalStringDBURL="jdbc:mysql://localhost:3306/zxy"; //定义数据库连接用户名

publicstaticfinalStringDBUSER="root"; //定义数据库连接密码

publicstaticfinalStringDBPASS="mysqladmin"; publicstaticvoidmain(String[]args){ Connectioncon=null; PreparedStatementpstmt=null; InputStreaminput=null; ResultSetrs=null; intid=1; Stringsql="SELECTname,noteFROMuserclobWHEREid=?"; try{ Class.forName(DBDRIVER); con=DriverManager.getConnection(DBURL,DBUSER,DBPASS); pstmt=con.prepareStatement(sql); pstmt.setInt(1,id);

rs=pstmt.executeQuery(); if(rs.next()){ Stringname=rs.getString(1); Clobclob=rs.getClob(2); Stringnote=clob.getSubString(1,(int)clob.length()); System.out.println("姓名:"+name); System.out.println("内容:"+note); clob.truncate(100); System.out.println("部分度取内容："+clob.getSubString(1,(int)clob.length())); pstmt.close(); con.close(); } }catch(ClassNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }

}}