Java使用JDBC向数据库存取大文本(比如小说等)

害恶细君

发布于 2022-11-22 08:16:19

9670

发布于 2022-11-22 08:16:19

文章被收录于专栏：编程技术总结分享

前言

之前学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();
    }
}

运行代码：