1. 创建一个 表 textfile
create table textfile
(
id int primary key auto_increment,
content longtext
);
2. 向 表 textfile的 content 字段中保存 文本文件
package com.jdbc7;
import java.io.File;
import java.io.FileReader;
import java.io.Reader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import com.db.DBUtil;
public class TestAdd {
/**
* @param args
*/
public static void main(String[] args) {
DBUtil db=new DBUtil();
Connection conn=db.openConnection();
String sql="insert into textfile(content)values(?)";
try {
PreparedStatement pstmt=conn.prepareStatement(sql);
File file=new File("C:/Users/tim/Desktop/text.txt");
Reader reader=new FileReader(file);
pstmt.setCharacterStream(1, reader,file.length());
pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}
finally
{
db.DBClose();
}
}
}
2. 读取 表 textfile 的 content 字段内容 存为文本文件
package com.jdbc7;
import java.io.File;
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 com.db.DBUtil;
public class TestFind {
/**
* @param args
*/
public static void main(String[] args) {
DBUtil db=new DBUtil();
Connection conn=db.openConnection();
String sql="select * from textfile where id=1";
try {
PreparedStatement pstmt=conn.prepareStatement(sql);
ResultSet rs=pstmt.executeQuery(sql);
StringBuilder sb=new StringBuilder();
if(rs.next())
{
Reader reader=rs.getCharacterStream("content");
int l=0;
char[] cbuf=new char[1024];
while((l=reader.read(cbuf))!=-1)
{
sb.append(new String(cbuf,0,l));
}
}
//将读取的数据存入文本文件
Writer writer=new FileWriter(new File("C:/Users/tim/Desktop/test2.txt"));
writer.write(sb.toString());
writer.flush();
writer.close();
} catch (Exception e) {
e.printStackTrace();
}
finally
{
db.DBClose();
}
}
}
