前言
之前学MySQL时，有学到过MySQL等数据库可以存储大文本，比如小说等。今天我刚好学完了JDBC，想拿这个应用来练练手。也算是给我的JDBC学习画上一个小句号，然后就去学连接池等，最后就学框架了。
一、使用JDBC向数据库存取小说
想要在数据库中读写大文本，就必须综合使用PreparedStatement和IO流的相关技术。
在MySQL等数据库中，TEXT数据类型可以存储1-65535个字符的不确定定长度的字符串，MEDIUMTEXT数据类型可以存储1-146万个字符的不确定长度的字符串，LONGTEXT可以存储1-42亿字符的不确定长度的字符串。
考虑到一本小说可能有几十万字，所以我就使用MEDIUMTEXT数据类型来存储小说等大文本。
二、具体实现步骤
1.打开MySQL，并创建一个名为novels的数据库，然后创建数据表。
代码如下（示例）：
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类。
代码如下（示例）：
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目录根)
代码如下（示例）：
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流的操作。
