将txt文件内容（以utf-8）存储到数据库中

╰半橙微兮° 2022-08-26 01:25 187阅读 0赞

package com.test.javaSe01;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileNotFoundException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.Reader;
    import java.io.UnsupportedEncodingException;
    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.Scanner;
    
    /**
     * 
     * @author Administrator
     * @see txt中的内容是中文的(utf-8格式)，将txt中的内容存储到数据库中
     */
    public class JDBCClobTestDemo01 {
    	public static void main(String[] args) throws SQLException,
    			FileNotFoundException, ClassNotFoundException,
    			UnsupportedEncodingException {
    		String url = "jdbc:mysql://localhost:3306/test?unicode=true&characterEncoding=utf8";
    		String driver = "com.mysql.jdbc.Driver";
    		String user = "root";
    		String password = "root";
    
    		Connection conn = null;
    		PreparedStatement ps = null;
    		Statement st = null;
    		ResultSet rs = null;
    		String sql = "insert into userclob values(id,?,?)";
    		Class.forName(driver);
    		File file = new File("H:\\a.txt");
    		InputStream input = new FileInputStream(file);
    		Reader reader = new InputStreamReader(input, "utf-8");
    		conn = DriverManager.getConnection(url, user, password);
    		try {
    			ps = conn.prepareStatement(sql);
    			ps.setString(1, "ctl");
    			// setAsciiStream() setBlob() setCharacterStream()只可以存储英文不可以存储汉字
    			// ps.setAsciiStream(2, input, (int) file.length());
    			ps.setNCharacterStream(2, reader, file.length());
    			ps.executeUpdate();
    			sql = "select * from userclob";
    			rs = ps.executeQuery(sql);
    			while (rs.next()) {
    				System.out.print(rs.getInt(1) + "\t");
    				System.out.print(rs.getString(2) + "\t");
    				// getAsciiStream(), getCharacterStream()
    				// getString()都可以获取类型longtext中的数据
    				// Scanner scanner = new Scanner(rs.getAsciiStream(3));
    				// Scanner scanner = new Scanner(rs.getCharacterStream(3));
    				Scanner scanner = new Scanner(rs.getString(3));
    				scanner.useDelimiter("\r\n");
    				StringBuffer sb = new StringBuffer();
    				while (scanner.hasNext()) {
    					sb.append(scanner.next()).append("\n");
    				}
    				System.out.println(sb);
    			}
    			ps.close();
    			conn.close();
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}
    	}
    }