前言
之前学MySQL时，有学到过MySQL等数据库可以存储大文本，比如小说等。今天我刚好学完了JDBC，想拿这个应用来练练手。也算是给我的JDBC学习画上一个小句号，然后就去学连接池等，最后就学框架了。
一、使用JDBC向数据库存取小说
想要在数据库中读写大文本，就必须综合使用PreparedStatement和IO流的相关技术。
在MySQL等数据库中，TEXT数据类型可以存储1-65535个字符的不确定定长度的字符串，MEDIUMTEXT数据类型可以存储1-146万个字符的不确定长度的字符串，LONGTEXT可以存储1-42亿字符的不确定长度的字符串。
考虑到一本小说可能有几十万字，所以我就使用MEDIUMTEXT数据类型来存储小说等大文本。
二、具体实现步骤 1.打开MySQL，并创建一个名为novels的数据库，然后创建数据表。
代码如下（示例）：
代码语言：javascript复制create database novels default character set = "utf8mb4";use novels;
create table myNovel(
id int primary key,
novel mediumtext
)2.将小说写入到数据库中myNovel表的novel字段。
思路：将小说转换为字符输入流，然后通过PreparedStatement的setCharacterStream()方法写入数据库中。
创建普通Java项目，把MySQL的jdbc驱动的jar包下载后，导入到项目中，在src目录下创建一个WriteAndReadNovel类，D盘根目录下有一个虫屋.txt的文本。然后编WriteAndReadNovel类。
代码如下（示例）：
代码语言：javascript复制import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.sql.*;
public class WriteAndReadNovel {
public static void writeNovelToMySQL(){
Connection conn=null;
PreparedStatement ps=null;
try {
//加载JDBC驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//定义连接字符串
String url="jdbc:mysql://localhost:3306/novels";
//用户名
String user="root";
//密码
String pwd="zc20020106";
//获取数据库连接
conn= DriverManager.getConnection(url,user,pwd);
//定义要执行的sql语句
String sql="insert into myNovel(id,novel) values (?,?)";
//创建获取PreparedStatement,处理text和blob必须使用PreparedStatement
ps=conn.prepareStatement(sql);
//给第一个？设为id为1
ps.setInt(1,1);
File file=new File("D:\虫屋.txt");
//将小说转为字符输入流，并设置编码格式为GBK
Reader reader =new InputStreamReader(new FileInputStream(file),"GBK");
//将字符输入流写入数据库
ps.setCharacterStream(2,reader,(int)file.length());
int result= ps.executeUpdate();
if (result>0){
System.out.println("小说写入成功");
}else {
System.out.println("小说写入失败");
}
}catch (Exception e){
e.printStackTrace();
}finally {
//释放资源
if (ps!=null){
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
writeNovelToMySQL();
}
}运行代码：
3.读取数据库里小说
思路：通过ResultSet的getCharacterStream()方法读取小说，然后通过IO流写入硬盘（src目录根)
代码如下（示例）：
代码语言：javascript复制import java.io.*;
import java.sql.*;
public static void readNovelToLocal(){
Connection conn=null;
PreparedStatement ps=null;
ResultSet rs=null;
try {
//加载JDBC驱动
Class.forName("com.mysql.cj.jdbc.Driver");
//定义连接字符串
String url="jdbc:mysql://localhost:3306/novels";
//用户名
String user="root";
//密码
String pwd="zc20020106";
//获取数据库连接
conn= DriverManager.getConnection(url,user,pwd);
//定义要执行的sql语句
String sql="select * from myNovel where id=?";
//创建获取PreparedStatement,处理text和blob必须使用PreparedStatement
ps=conn.prepareStatement(sql);
//第一个？设置id为1
ps.setInt(1,1);
//获取结果集
rs=ps.executeQuery();
//获取结果
if (rs.next()){
//将小说从数据库中读取出来，流类型为Reader
Reader reader=rs.getCharacterStream("novel");
//通过io流将小说写到本地项目中去(硬盘)
//小说的输出目录为src（相对路径）
Writer writer=new FileWriter("src/虫屋.txt");
char[] temp=new char[200];
int len=-1;
while ((len=reader.read(temp))!=-1){
writer.write(temp,0,len);
}
writer.close();
reader.close();
System.out.println("小说读取成功！");
}
}catch (Exception e){
e.printStackTrace();
}finally {
//释放资源
if (rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps!=null){
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
readNovelToLocal();
}
}运行代码：
总结
jdbc其实很简单，代码按套路来就行。今天这个应用案例用到的知识点就是jdbc的Preparedstatement和io流的操作。
