欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

更改MySQL數(shù)據(jù)庫(kù)的編碼為utf8mb4問(wèn)題

 更新時(shí)間：2022年11月08日 10:53:00   作者：woslx  
這篇文章主要介紹了更改MySQL數(shù)據(jù)庫(kù)的編碼為utf8mb4問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

utf-8編碼可能1個(gè)字節(jié)、2個(gè)字節(jié)、3個(gè)字節(jié)、4個(gè)字節(jié)的字符，但是MySQL的utf8編碼只支持最多3字節(jié)的數(shù)據(jù)，也就是說(shuō)mysql最開(kāi)始的時(shí)候，對(duì)utf-8的支持是不完整的。而emoji表情字符是4個(gè)字節(jié)的字符。

如果直接往采用utf-8編碼的數(shù)據(jù)庫(kù)中插入表情數(shù)據(jù)

java程序中將報(bào)SQL異常：

java.sql.SQLException: Incorrect string value: ‘\xF0\x9F\x92\x94’ for column ‘name’ at row 1
at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1073)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3593)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3525)
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1986)
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2140)
at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2620)
at com.mysql.jdbc.StatementImpl.executeUpdate(StatementImpl.java:1662)
at com.mysql.jdbc.StatementImpl.executeUpdate(StatementImpl.java:1581)

可以對(duì)4字節(jié)的字符進(jìn)行編碼存儲(chǔ)，然后取出來(lái)的時(shí)候，再進(jìn)行解碼。但是這樣做會(huì)使得任何使用該字符的地方都要進(jìn)行編碼與解碼。

為了支持完整的utf-8編碼，mysql推出了utf8mb4，它是mysql平臺(tái)上utf8編碼的超集，兼容utf8，并且能存儲(chǔ)4字節(jié)的表情字符。

采用utf8mb4編碼的好處是：存儲(chǔ)與獲取數(shù)據(jù)的時(shí)候，不用再考慮表情字符的編碼與解碼問(wèn)題。

更改數(shù)據(jù)庫(kù)的編碼為utf8mb4:

1. MySQL的版本

utf8mb4的最低mysql版本支持版本為5.5.3+，若不是，請(qǐng)升級(jí)到較新版本。

2. MySQL驅(qū)動(dòng)

5.1.34可用,最低不能低于5.1.13

3. 修改MySQL配置文件

修改mysql配置文件my.cnf（windows為my.ini）

my.cnf一般在/etc/mysql/my.cnf位置。找到后請(qǐng)?jiān)谝韵氯糠掷锾砑尤缦聝?nèi)容：

[client]?
default-character-set = utf8mb4?
[mysql]?
default-character-set = utf8mb4?
[mysqld]?
character-set-client-handshake = FALSE?
character-set-server = utf8mb4?
collation-server = utf8mb4_unicode_ci?
init_connect='SET NAMES utf8mb4'

4. 重啟數(shù)據(jù)庫(kù)，檢查變量

SHOW VARIABLES WHERE Variable_name LIKE ?'character_set_%' ?OR Variable_name LIKE 'collation%';
Variable_nameValue
character_set_clientutf8mb4
character_set_connectionutf8mb4
character_set_databaseutf8mb4
character_set_filesystembinary
character_set_resultsutf8mb4
character_set_serverutf8mb4
character_set_systemutf8
collation_connectionutf8mb4_unicode_ci
collation_databaseutf8mb4_unicode_ci
collation_serverutf8mb4_unicode_ci

collation_connection 、collation_database 、collation_server是什么沒(méi)關(guān)系。

但必須保證下面幾個(gè)變量必須是utf8mb4。

系統(tǒng)變量描述
character_set_client(客戶端來(lái)源數(shù)據(jù)使用的字符集)
character_set_connection(連接層字符集)
character_set_database(當(dāng)前選中數(shù)據(jù)庫(kù)的默認(rèn)字符集)
character_set_results(查詢結(jié)果字符集)
character_set_server(默認(rèn)的內(nèi)部操作字符集)

5. 數(shù)據(jù)庫(kù)連接的配置

數(shù)據(jù)庫(kù)連接參數(shù)中：

characterEncoding=utf8會(huì)被自動(dòng)識(shí)別為utf8mb4，也可以不加這個(gè)參數(shù)，會(huì)自動(dòng)檢測(cè)。

而autoReconnect=true是必須加上的。

6. 將數(shù)據(jù)庫(kù)和已經(jīng)建好的表也轉(zhuǎn)換成utf8mb4

更改數(shù)據(jù)庫(kù)編碼：

ALTER DATABASE caitu99 CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`;

更改表編碼：

ALTER TABLE `TABLE_NAME` CONVERT TO CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`;

如有必要，還可以更改列的編碼

可以寫(xiě)代碼批量進(jìn)行轉(zhuǎn)換：

//獲取所有表
Connection conn = null;

try {
    conn = DbUtilsTool.openConn("MySQL", "127.0.0.1", "3306", "caitu99", "root", "root");
    String sql = "show tables";
    QueryRunner qr = new QueryRunner();
    List<String> tblNameList= (List<String>) qr.query(conn, sql, new ColumnListHandler(1));
    sql = "ALTER DATABASE caitu99 CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`";
    qr.update(conn,sql);
    for (String str:tblNameList)
    {
        sql = "ALTER TABLE "+str+" CONVERT TO CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`";
        qr.update(conn,sql);
    }
}
catch (Exception e)
{
            e.printStackTrace();
            throw new RuntimeException(e);
}
finally {
    if(conn!=null) {
        try {
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
   }
}

DbUtilsTool類：

package com.mysql.chartest;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import org.apache.commons.dbutils.BasicRowProcessor;
import org.apache.commons.dbutils.BeanProcessor;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.ArrayHandler;
import org.apache.commons.dbutils.handlers.ArrayListHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ColumnListHandler;
import org.apache.commons.dbutils.handlers.KeyedHandler;
import org.apache.commons.dbutils.handlers.MapHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;

public class DbUtilsTool {
    private static final QueryRunner runner = new QueryRunner();

    /* 打開(kāi)數(shù)據(jù)庫(kù)連接（type: MySQL，Oracle，SQLServer） */
    public static Connection openConn(String type,      //數(shù)據(jù)庫(kù)類型
                                      String host,      //主機(jī)ip
                                      String port,      //主機(jī)端口
                                      String name,      //數(shù)據(jù)庫(kù)名
                                      String username,  //用戶名
                                      String password)//密碼
     {
        Connection conn = null;
        try {
            String driver;
            String url;
            if (type.equalsIgnoreCase("MySQL")) {
                driver = "com.mysql.jdbc.Driver";
                url = "jdbc:mysql://" + host + ":" + port + "/" + name;
            } else if (type.equalsIgnoreCase("Oracle")) {
                driver = "oracle.jdbc.driver.OracleDriver";
                url = "jdbc:oracle:thin:@" + host + ":" + port + ":" + name;
            } else if (type.equalsIgnoreCase("SQLServer")) {
                driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
                url = "jdbc:sqlserver://" + host + ":" + port + ";databaseName=" + name;
            } else {
                throw new RuntimeException();
            }
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }

    /* 關(guān)閉數(shù)據(jù)庫(kù)連接 */
    public static void closeConn(Connection conn) {
        try {
            if (conn != null) {
                conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /* 查詢（返回Array結(jié)果） */
    public static Object[] queryArray(Connection conn, String sql, Object... params) {
        Object[] result = null;
        try {
            result = runner.query(conn, sql, new ArrayHandler(), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢（返回ArrayList結(jié)果） */
    public static List<Object[]> queryArrayList(Connection conn, String sql, Object... params) {
        List<Object[]> result = null;
        try {
            result = runner.query(conn, sql, new ArrayListHandler(), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢（返回Map結(jié)果） */
    public static Map<String, Object> queryMap(Connection conn, String sql, Object... params) {
        Map<String, Object> result = null;
        try {
            result = runner.query(conn, sql, new MapHandler(), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢（返回MapList結(jié)果） */
    public static List<Map<String, Object>> queryMapList(Connection conn, String sql, Object... params) {
        List<Map<String, Object>> result = null;
        try {
            result = runner.query(conn, sql, new MapListHandler(), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢（返回Bean結(jié)果） */
    public static <T> T queryBean(Class<T> cls, Map<String, String> map, Connection conn, String sql, Object... params) {
        T result = null;
        try {
            if (map != null) {
                result = runner.query(conn, sql, new BeanHandler<T>(cls, new BasicRowProcessor(new BeanProcessor(map))), params);
            } else {
                result = runner.query(conn, sql, new BeanHandler<T>(cls), params);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢（返回BeanList結(jié)果） */
    public static <T> List<T> queryBeanList(Class<T> cls, Map<String, String> map, Connection conn, String sql, Object... params) {
        List<T> result = null;
        try {
            if (map != null) {
                result = runner.query(conn, sql, new BeanListHandler<T>(cls, new BasicRowProcessor(new BeanProcessor(map))), params);
            } else {
                result = runner.query(conn, sql, new BeanListHandler<T>(cls), params);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢指定列名的值（單條數(shù)據(jù)） */
    public static <T> T queryColumn(String column, Connection conn, String sql, Object... params) {
        T result = null;
        try {
            result = runner.query(conn, sql, new ScalarHandler<T>(column), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢指定列名的值（多條數(shù)據(jù)） */
    public static <T> List<T> queryColumnList(String column, Connection conn, String sql, Object... params) {
        List<T> result = null;
        try {
            result = runner.query(conn, sql, new ColumnListHandler<T>(column), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 查詢指定列名對(duì)應(yīng)的記錄映射 */
    public static <T> Map<T, Map<String, Object>> queryKeyMap(String column, Connection conn, String sql, Object... params) {
        Map<T, Map<String, Object>> result = null;
        try {
            result = runner.query(conn, sql, new KeyedHandler<T>(column), params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }

    /* 更新（包括UPDATE、INSERT、DELETE，返回受影響的行數(shù)） */
    public static int update(Connection conn, String sql, Object... params) {
        int result = 0;
        try {
            result = runner.update(conn, sql, params);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return result;
    }
}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論