您好,欢迎访问一九零五行业门户网

JDBC大数据存取_MySQL

//大数据存取,程序一般不把大文本或二进制数据保存到数据库;
//大数据分为clob 用于存储文本; blob 用于存储 二进制数据,如图像,声音, 二进制文件。
// mysql 没有clob,只有text;
1. 封装连接数据工具类
2 大数据存取
import java.io.file;
import java.io.filereader;
import java.io.filewriter;
import java.io.reader;
import java.io.writer;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import org.junit.test;
public class cloabdemo {
 @test
 public void add(){
  connection conn = null;
  preparedstatement pstmt = null;
try {
   conn = jdbcutil.getconnection();//
   string sql = insert into t1(id,content) values(?,?) ;
   pstmt = jdbcutil.prepare(conn, sql);
    pstmt.setint(1, 1);
    //大数据 要使用流的形式
    file file = new file(d:/clob.txt);
    reader reader = new filereader(file);
    pstmt.setcharacterstream(2, reader, (int)file.length()); //不能使用long的参数, mysql支持不到那么大的数据
    int i =pstmt.executeupdate();
    if(i>0){
     system.out.println(插入成功);
    }
   } catch (exception e) {
    // todo auto-generated catch block
    e.printstacktrace();
   }
   finally{
    jdbcutil.closeconn(conn, pstmt, null);
   }
 }
 //读
 @test
 public void read(){
connection conn = null;
  preparedstatement pstmt = null;
  resultset rs = null;
try {
   conn = jdbcutil.getconnection();//
   string sql = select * from t1 where id =?;
   pstmt = conn.preparestatement(sql);
    pstmt.setint(1, 1);
    //大数据 要使用流的形式
    //保存到e盘
    rs=pstmt.executequery(sql);
    if(rs.next()){
reader reader = rs.getcharacterstream(content);
     writer writer = new filewriter(e:/clob.txt);
     char[] c = new char[1024];
     int len =-1;
     while ((len=reader.read(c))!=-1){
      writer.write(c, 0, len);
     }
     reader.close();
     writer.close();
    }
   } catch (exception e) {
    // todo auto-generated catch block
    e.printstacktrace();
   }
   finally{
    jdbcutil.closeconn(conn, pstmt, null);
   }
}
}

其它类似信息

推荐信息