golang/hotime
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 85 Wiki Activity

Merge branch 'master' of https://code.hoteas.com/golang/hotime

Browse Source
This commit is contained in:
hoteas
2026-07-22 04:41:30 +08:00
parent ec9d25fef6 a600fa8a15
commit 412f08a048
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
application.go
+2 -2
View File
@@ -781,7 +781,7 @@ func SetMysqlDB(appIns *Application, config Map) {
appIns.Db.Log = appIns.Log
appIns.SetConnectDB(func() (master, slave *sql.DB) {
query := config.GetString("user") + ":" + config.GetString("password") +
"@tcp(" + config.GetString("host") + ":" + config.GetString("port") + ")/" + config.GetString("name") + "?charset=utf8"
"@tcp(" + config.GetString("host") + ":" + config.GetString("port") + ")/" + config.GetString("name") + "?charset=utf8mb4"
DB, e := sql.Open("mysql", query)
if e != nil {
appIns.Log.Error().Err(e).Msg("MySQL 主库连接失败")
@@ -790,7 +790,7 @@ func SetMysqlDB(appIns *Application, config Map) {
configSlave := config.GetMap("slave")
if configSlave != nil {
query := configSlave.GetString("user") + ":" + configSlave.GetString("password") +
"@tcp(" + config.GetString("host") + ":" + configSlave.GetString("port") + ")/" + configSlave.GetString("name") + "?charset=utf8"
"@tcp(" + config.GetString("host") + ":" + configSlave.GetString("port") + ")/" + configSlave.GetString("name") + "?charset=utf8mb4"
DB1, e := sql.Open("mysql", query)
if e != nil {
appIns.Log.Error().Err(e).Msg("MySQL 从库连接失败")
docs/HoTimeDB_使用说明.md
+3 -1
View File
@@ -33,6 +33,8 @@ HoTimeDB是一个基于Golang实现的轻量级ORM框架，参考PHP Medoo设计
### 初始化数据库连接
`Application.SetMysqlDB` 默认 DSN 带 `charset=utf8mb4`（兼容 MySQL 8.0 / 8.4，与表字符集对齐）。
```go
import (
"code.hoteas.com/golang/hotime/db"
@@ -43,7 +45,7 @@ import (
// 创建连接函数
func createConnection() (master, slave *sql.DB) {
master, _ = sql.Open("mysql", "user:password@tcp(localhost:3306)/database")
master, _ = sql.Open("mysql", "user:password@tcp(localhost:3306)/database?charset=utf8mb4")
// slave是可选的，用于读写分离
slave = master // 或者连接到从数据库
return