更改MySQL數(shù)據(jù)庫的編碼為utf8mb4問題
utf-8編碼可能1個字節(jié)、2個字節(jié)、3個字節(jié)、4個字節(jié)的字符,但是MySQL的utf8編碼只支持最多3字節(jié)的數(shù)據(jù),也就是說mysql最開始的時候,對utf-8的支持是不完整的。而emoji表情字符是4個字節(jié)的字符。
如果直接往采用utf-8編碼的數(shù)據(jù)庫中插入表情數(shù)據(jù)
java程序中將報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)
可以對4字節(jié)的字符進(jìn)行編碼存儲,然后取出來的時候,再進(jìn)行解碼。但是這樣做會使得任何使用該字符的地方都要進(jìn)行編碼與解碼。
為了支持完整的utf-8編碼,mysql推出了utf8mb4,它是mysql平臺上utf8編碼的超集,兼容utf8,并且能存儲4字節(jié)的表情字符。
采用utf8mb4編碼的好處是:存儲與獲取數(shù)據(jù)的時候,不用再考慮表情字符的編碼與解碼問題。
更改數(shù)據(jù)庫的編碼為utf8mb4:
1. MySQL的版本
utf8mb4的最低mysql版本支持版本為5.5.3+,若不是,請升級到較新版本。
2. MySQL驅(qū)動
5.1.34可用,最低不能低于5.1.13
3. 修改MySQL配置文件
修改mysql配置文件my.cnf(windows為my.ini)
my.cnf一般在/etc/mysql/my.cnf位置。找到后請在以下三部分里添加如下內(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ù)庫,檢查變量
SHOW VARIABLES WHERE Variable_name LIKE ?'character_set_%' ?OR Variable_name LIKE 'collation%';
| Variable_name | Value |
|---|---|
| character_set_client | utf8mb4 |
| character_set_connection | utf8mb4 |
| character_set_database | utf8mb4 |
| character_set_filesystem | binary |
| character_set_results | utf8mb4 |
| character_set_server | utf8mb4 |
| character_set_system | utf8 |
| collation_connection | utf8mb4_unicode_ci |
| collation_database | utf8mb4_unicode_ci |
| collation_server | utf8mb4_unicode_ci |
collation_connection 、collation_database 、collation_server是什么沒關(guān)系。
但必須保證下面幾個變量必須是utf8mb4。
| 系統(tǒng)變量 | 描述 |
|---|---|
| character_set_client | (客戶端來源數(shù)據(jù)使用的字符集) |
| character_set_connection | (連接層字符集) |
| character_set_database | (當(dāng)前選中數(shù)據(jù)庫的默認(rèn)字符集) |
| character_set_results | (查詢結(jié)果字符集) |
| character_set_server | (默認(rèn)的內(nèi)部操作字符集) |
5. 數(shù)據(jù)庫連接的配置
數(shù)據(jù)庫連接參數(shù)中:
characterEncoding=utf8會被自動識別為utf8mb4,也可以不加這個參數(shù),會自動檢測。
而autoReconnect=true是必須加上的。
6. 將數(shù)據(jù)庫和已經(jīng)建好的表也轉(zhuǎn)換成utf8mb4
更改數(shù)據(jù)庫編碼:
ALTER DATABASE caitu99 CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`;
更改表編碼:
ALTER TABLE `TABLE_NAME` CONVERT TO CHARACTER SET `utf8mb4` COLLATE `utf8mb4_general_ci`;
如有必要,還可以更改列的編碼
可以寫代碼批量進(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();
/* 打開數(shù)據(jù)庫連接(type: MySQL,Oracle,SQLServer) */
public static Connection openConn(String type, //數(shù)據(jù)庫類型
String host, //主機ip
String port, //主機端口
String name, //數(shù)據(jù)庫名
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ù)庫連接 */
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;
}
/* 查詢指定列名對應(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;
}
}
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
MySQL 創(chuàng)建主鍵,外鍵和復(fù)合主鍵的語句
MySQL 創(chuàng)建主鍵,外鍵和復(fù)合主鍵的方法,需要的朋友可以參考下。2009-12-12
mysql 8.0.17 winx64(附加navicat)手動配置版安裝教程圖解
這篇文章主要介紹了mysql 8.0.17 winx64(附加navicat)手動配置版安裝教程圖解,非常不錯,具有一定的參考借鑒價值,需要的朋友可以參考下2019-08-08
MYSQL數(shù)據(jù)庫Innodb?引擎mvcc鎖實現(xiàn)原理
這篇文章主要介紹了MYSQL數(shù)據(jù)庫Innodb?引擎mvcc鎖實現(xiàn)原理,但是mvcc?的實現(xiàn)原理是什么呢?下文我們就來實例說明來mvcc?的實現(xiàn)原理,感興趣的小伙伴可以參考一下2022-05-05

