TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-06 01:50:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

设置 max_prepared_stmt_count 失败时提示更详细

Browse Source
This commit is contained in:
刘祥超
2021-07-21 09:01:37 +08:00
parent 514d968b20
commit fe4eb3928e
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
internal/nodes/api_node.go
View File

@@ -293,7 +293,10 @@ func (this *APINode) setupDB() error {
if valueInt < 65535 { if valueInt < 65535 {
_, err := db.Exec("SET GLOBAL max_prepared_stmt_count=65535") _, err := db.Exec("SET GLOBAL max_prepared_stmt_count=65535")
if err != nil { if err != nil {
return err return errors.New("run 'SET GLOBAL max_prepared_stmt_count' on database failed: " + err.Error() + ", \nyou can change the variable in 'my.cnf': \n~~~\n" + `[mysqld]
max_prepared_stmt_count=65535
~~~
then restart mysqld.`)
} }
} }
} }
@@ -316,7 +319,7 @@ func (this *APINode) listenPorts(apiNode *models.APINode) (isListening bool) {
for _, addr := range listen.Addresses() { for _, addr := range listen.Addresses() {
listener, err := net.Listen("tcp", addr) listener, err := net.Listen("tcp", addr)
if err != nil { if err != nil {
remotelogs.Error("API_NODE", "listening '"+addr+"' failed: "+err.Error() + ", we will try to listen port only") remotelogs.Error("API_NODE", "listening '"+addr+"' failed: "+err.Error()+", we will try to listen port only")
// 试着只监听端口 // 试着只监听端口
_, port, err := net.SplitHostPort(addr) _, port, err := net.SplitHostPort(addr)
@@ -364,7 +367,7 @@ func (this *APINode) listenPorts(apiNode *models.APINode) (isListening bool) {
for _, addr := range listen.Addresses() { for _, addr := range listen.Addresses() {
listener, err := net.Listen("tcp", addr) listener, err := net.Listen("tcp", addr)
if err != nil { if err != nil {
remotelogs.Error("API_NODE", "listening '"+addr+"' failed: "+err.Error() + ", we will try to listen port only") remotelogs.Error("API_NODE", "listening '"+addr+"' failed: "+err.Error()+", we will try to listen port only")
// 试着只监听端口 // 试着只监听端口
_, port, err := net.SplitHostPort(addr) _, port, err := net.SplitHostPort(addr)
if err != nil { if err != nil {