//大数据存取,程序一般不把大文本或二进制数据保存到数据库;
//大数据分为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);
}
}
}