JDBC Part02：大字段封装JDBC工具类

一、大字段

1.1、大字段概念

对于字段长度要求超过 255 个的情况下，MySQL 提供了 TEXT 和 BLOB 两种类型。根据存储数据的大小，它们都有不同的子类型。这些大型的数据用于存储文本块或图像、声音文件等二进制数据类型

1.2 、大字段类型

4种文本: TINYTEXT(0-255字节)、TEXT(0-65535字节)、MEDIUMTEXT(0-16777215字节) 和 LONGTEXT(0-4294967295字节)
4种二进制: TINYBLOB(0-255字节)、BLOB(0-65535字节)、MEDIUMBLOB(0-16777215字节) 和 LONGBLOB(0-4294967295字节)

1.3、具体使用图示

image

1.4、大字段的操作

创建保存大字段的表

CREATE TABLE user(
    `id` INT NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
    `image` MEDIUMBLOB  COMMENT '图片',
    `article` TEXT NOT NULL COMMENT '大字段文本'
)ENGINE=InnoDB DEFAULT CHARSET=UTF8;

操作数据库中大字段示例代码

package jdbcmysql;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.InputStream;
import java.io.Reader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;


public class JdbcPart04Demo01Copy01 {
    static int iCounter=0;
    
    public void setData() throws Exception{
        
        //获取connection连接
        Connection con = Utilities.getConnection();
        //创建sql语句
        String sql= "INSERT INTO others (id,image,article) VALUES (NULL,?,?) ";
        //获取PrepareStatement 对象。
        PreparedStatement pst = con.prepareStatement(sql);
        //获取文件输入流，用于将本地文件输入进程序
        FileInputStream fis =new FileInputStream("F:\\360downloads\\Sword.jpg");
        //调用pst中方法对sql语句进行预编译
        
        pst.setBinaryStream(1, fis, fis.available());
        System.out.println("image预编译完成");
        
        
        File file=new File("D:\\Test\\copy.txt");
        FileReader fr=new FileReader(file);
        pst.setCharacterStream(2, fr);
        
        //调用executeUpdate方法写入数据
        int low = pst.executeUpdate();      
    
        if(low>0){
            fis.close();
            System.out.println("数据写入数据库成功~~~");
        }
        pst.close();
        con.close();
    }
    
    
    public void getData() throws Exception{
        
        Connection con = Utilities.getConnection();
        
        String sql="SELECT image,article FROM others";
        
        PreparedStatement pst = con.prepareStatement(sql);
        
        ResultSet query = pst.executeQuery();
        
        
        while(query.next()){
            iCounter++;
            
            //获取数据库字节输入流
            InputStream bis = query.getBinaryStream("image");
            //获取本地文件字节输出流
            
            FileOutputStream fos=new FileOutputStream("Kmono"+iCounter+".jpg");
            
            //创建缓存数组
            byte[] bs=new byte[8192];
            int len;
            
            while((len = bis.read(bs))!=-1){
                
                fos.write(bs, 0, len);
            }
            
            fos.close();
            Reader reader = query.getCharacterStream("article");
            
            FileWriter fw=new FileWriter("test"+iCounter+".txt");
            
            char [] ch=new char[1024];
            
            
            while((len = reader.read(ch))!=-1){
                
                fw.write(ch, 0, len);
            }
            
            fw.close();
            
        }
        
        pst.close();
        con.close();
    
        System.out.println("读取完毕~~");
    }   
}

二、JDBC工具类的封装

- 封装获取和关闭数据库连接的工具类

①获取数据库连接
--加载数据库驱动
--获取数据库连接
②关闭数据库连接
--关闭ResultSet
--关闭PreparedStatement
--关闭Connection

实现代码(动态)
step1：编写 .properties 文件,并将该文件置于src目录下

URL=jdbc:mysql://localhost:3306/seventest?characterEncoding=utf-8
USERNAME=root
PASSWORD=4567

package utilities;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;


/**
 * 封装一个JDBC工具类，提供获取数据库连接，关闭资源的方法
 * @author 86183
 *
 */
public class Jdbc_Utilities {
    
    private static Properties p=null;
    
    static{
        p=new Properties();
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //链式编码：获取Jdbc_utilities的Class类对象，通过该对象获取构造器。然后再获取读取本地配置文件输入流
        InputStream ris = Jdbc_Utilities.class.getClassLoader().getResourceAsStream("db.properties");
        try {
            p.load(ris);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    private Jdbc_Utilities(){
        
    }
    
    
    /**
     * @throws SQLException 
     * 获取数据库连接
     */
    public static  Connection getConnection() throws SQLException{
         
        return  DriverManager.getConnection(p.getProperty("URL"),p.getProperty("USERNAME"),p.getProperty("PASSWORD"));
    }
    
    /**
     * 关闭数据库连接
     * @param con
     */
    public static void closeResource(Connection con){
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
    /**
     * 关闭资源
     * @param con 数据库连接对象
     * @param stmt Statement 对象
     */
    public static void closeResource(Connection con,Statement stmt){
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        if(stmt!=null){
            try {
                stmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
    }
    /**
     * 关闭资源
     * @param con 数据库连接对象
     * @param stmt Statement对象
     * @param query 结果集（ResultSet）
     */
    public static void closeResource(Connection con,Statement stmt,ResultSet query){

        if(query!=null){
            try {
                query.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if(stmt!=null){
            try {
                stmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }   
    }
    /**
     * 关闭资源
     * @param con 数据库连接对象
     * @param pstmt prepareStatement对象
     */
    public static void closeResource(Connection con,PreparedStatement pstmt){
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
        if(pstmt!=null){
            try {
                pstmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
    }
    /**
     * 关闭资源
     * @param con 数据库连接对象
     * @param pstmt PrepareStatement对象
     * @param query Resuset结果集
     */
    public static void closeResource(Connection con,PreparedStatement pstmt,ResultSet query){

        if(query!=null){
            try {
                query.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        if(pstmt!=null){
            try {
                pstmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
        if(con!=null){
            try {
                con.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }   
    }
}

JDBC Part02：大字段 封装JDBC工具类

一、大字段

1.1、大字段概念

1.2 、大字段类型

1.3、具体使用图示

1.4、大字段的操作

二、JDBC工具类的封装

JDBC Part02：大字段封装JDBC工具类