fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改mysql连接

Browse Source
This commit is contained in:
eson 2023-08-22 13:43:13 +08:00
parent d35ffd793a
commit 2dee02b6c5
29 changed files with 41 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
generator/main.go
View File

@ -53,7 +53,7 @@ func GetAllTableNames(uri string) []string {
return tableNames return tableNames
} }
// "fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest" // "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"
func GetColsFromTable(tname string, db *sql.DB) (result []Column, tableName, tableComment string) { func GetColsFromTable(tname string, db *sql.DB) (result []Column, tableName, tableComment string) {
var a, ddl string var a, ddl string
@ -210,7 +210,7 @@ func main() {
var name string // 需要序列化的单独文件名 var name string // 需要序列化的单独文件名
var mdir string // 需要修改的序列化路径 model var mdir string // 需要修改的序列化路径 model
flag.StringVar(&mysqluri, "uri", "fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest", "输入需要序列化的ddl文件名, 不需要后缀.ddl") flag.StringVar(&mysqluri, "uri", "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen", "输入需要序列化的ddl文件名, 不需要后缀.ddl")
flag.StringVar(&name, "name", "", "输入需要序列化的ddl文件名, 不需要后缀.ddl") flag.StringVar(&name, "name", "", "输入需要序列化的ddl文件名, 不需要后缀.ddl")
flag.StringVar(&mdir, "mdir", "", "输入需要生成model的Go文件所在目录") flag.StringVar(&mdir, "mdir", "", "输入需要生成model的Go文件所在目录")

2
goctl_template/api/etc.tpl
View File

@ -2,7 +2,7 @@ Name: {{.serviceName}}
Host: {{.host}} Host: {{.host}}
Port: {{.port}} Port: {{.port}}
Timeout: 15000 #服务超时时间(毫秒) Timeout: 15000 #服务超时时间(毫秒)
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
SourceRabbitMq: amqp://rabbit001:rabbit001129@110.41.19.98:5672 SourceRabbitMq: amqp://rabbit001:rabbit001129@110.41.19.98:5672
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023

2
goctl_template_backend/api/etc.tpl
View File

@ -1,7 +1,7 @@
Name: {{.serviceName}} Name: {{.serviceName}}
Host: {{.host}} Host: {{.host}}
Port: {{.port}} Port: {{.port}}
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

5
initalize/mysql.go
View File

@ -1,10 +1,12 @@
package initalize package initalize
import ( import (
"log"
"time"
"gorm.io/driver/mysql" "gorm.io/driver/mysql"
"gorm.io/gorm" "gorm.io/gorm"
"gorm.io/gorm/schema" "gorm.io/gorm/schema"
"time"
) )
// 初始化mysql // 初始化mysql
@ -24,6 +26,7 @@ func InitMysql(sourceMysql string) *gorm.DB {
}, },
SkipDefaultTransaction: true, SkipDefaultTransaction: true,
}) })
log.Println(db.Rows())
if err != nil { if err != nil {
panic(err) panic(err)
} }

2
server/assistant/etc/assistant.yaml
View File

@ -2,7 +2,7 @@ Name: assistant
Host: 0.0.0.0 Host: 0.0.0.0
Port: 9950 Port: 9950
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

4
server/auth/etc/auth.yaml
View File

@ -2,8 +2,8 @@ Name: auth
Host: localhost Host: localhost
Port: 9980 Port: 9980
ReplicaId: 10 ReplicaId: 10
MainAddress: "http://localhost:9900" MainAddress: "https://server.fusen.3718.cn:9900"
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

1
server/backend/backend.go
View File

@ -23,7 +23,6 @@ func main() {
conf.MustLoad(*configFile, &c) conf.MustLoad(*configFile, &c)
server := rest.MustNewServer(c.RestConf, rest.WithCustomCors(auth.FsCors, func(w http.ResponseWriter) { server := rest.MustNewServer(c.RestConf, rest.WithCustomCors(auth.FsCors, func(w http.ResponseWriter) {
})) }))
defer server.Stop() defer server.Stop()

2
server/backend/etc/backend.yaml
View File

@ -2,7 +2,7 @@ Name: backend
Host: localhost Host: localhost
Port: 9901 Port: 9901
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen_backend_2023 AccessSecret: fusen_backend_2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/base/etc/base.yaml
View File

@ -2,7 +2,7 @@ Name: base
Host: 0.0.0.0 Host: 0.0.0.0
Port: 9920 Port: 9920
Timeout: 15000 #服务超时时间(毫秒) Timeout: 15000 #服务超时时间(毫秒)
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/canteen/etc/canteen.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9902 Port: 9902
ReplicaId: 15 ReplicaId: 15
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/data-transfer/etc/data-transfer.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9903 Port: 9903
ReplicaId: 20 ReplicaId: 20
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/home-user-auth/etc/home-user-auth.yaml
View File

@ -4,7 +4,7 @@ Port: 9904
ReplicaId: 25 ReplicaId: 25
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
MainAddress: "http://localhost:9900" MainAddress: "http://localhost:9900"
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023

2
server/inventory/etc/inventory.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9905 Port: 9905
ReplicaId: 30 ReplicaId: 30
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/map-library/etc/map-library.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9906 Port: 9906
ReplicaId: 35 ReplicaId: 35
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/orders/etc/orders.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9907 Port: 9907
ReplicaId: 40 ReplicaId: 40
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/pay/etc/pay.yaml
View File

@ -3,7 +3,7 @@ Host: 0.0.0.0
Port: 9915 Port: 9915
ReplicaId: 45 ReplicaId: 45
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/product-model/etc/product-model.yaml
View File

@ -1,7 +1,7 @@
Name: product-model Name: product-model
Host: localhost Host: localhost
Port: 9909 Port: 9909
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/product-template-tag/etc/product-template-tag.yaml
View File

@ -3,7 +3,7 @@ Host: 0.0.0.0
ReplicaId: 10 ReplicaId: 10
Port: 9917 Port: 9917
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/product-template/etc/product-template.yaml
View File

@ -2,7 +2,7 @@ Name: product-template
Host: localhost Host: localhost
Port: 9910 Port: 9910
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/product/etc/product.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9908 Port: 9908
ReplicaId: 50 ReplicaId: 50
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/render/etc/render.yaml
View File

@ -3,7 +3,7 @@ Host: 0.0.0.0
Port: 9919 Port: 9919
ReplicaId: 55 ReplicaId: 55
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/resource/etc/resource.yaml
View File

@ -3,7 +3,7 @@ Host: 0.0.0.0
Port: 9916 Port: 9916
ReplicaId: 60 ReplicaId: 60
Timeout: 150000 #服务超时时间(毫秒) Timeout: 150000 #服务超时时间(毫秒)
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/shopping-cart-confirmation/etc/shopping-cart-confirmation.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9911 Port: 9911
ReplicaId: 65 ReplicaId: 65
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/upload/etc/upload.yaml
View File

@ -4,7 +4,7 @@ Port: 9912
ReplicaId: 70 ReplicaId: 70
Timeout: 150000 #服务超时时间 Timeout: 150000 #服务超时时间
MaxBytes: 104857600 #传输字节大小 MaxBytes: 104857600 #传输字节大小
SourceMysql: "fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest" SourceMysql: "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"
Env: "test" Env: "test"
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023

2
server/webset/etc/webset.yaml
View File

@ -3,7 +3,7 @@ Host: localhost
Port: 9913 Port: 9913
ReplicaId: 75 ReplicaId: 75
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: "fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest" SourceMysql: "fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

2
server/websocket/etc/websocket.yaml
View File

@ -3,7 +3,7 @@ Host: 0.0.0.0
Port: 9914 Port: 9914
ReplicaId: 80 ReplicaId: 80
Timeout: 15000 #服务超时时间 Timeout: 15000 #服务超时时间
SourceMysql: fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest SourceMysql: fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen
Auth: Auth:
AccessSecret: fusen2023 AccessSecret: fusen2023
AccessExpire: 2592000 AccessExpire: 2592000

4
shared/main.go
View File

@ -23,7 +23,7 @@ import (
func test1() { func test1() {
// log.SetFlags(log.Llongfile) // log.SetFlags(log.Llongfile)
// fsm := StartNode("fs1", "localhost:5500", nil, initalize.InitMysql("fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest")) // fsm := StartNode("fs1", "localhost:5500", nil, initalize.InitMysql("fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"))
// time.Sleep(time.Second * 5) // time.Sleep(time.Second * 5)
@ -264,7 +264,7 @@ func waitForCluster(ra *raft.Raft) {
} }
} }
// var gdb *gorm.DB = initalize.InitMysql("fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest") // var gdb *gorm.DB = initalize.InitMysql("fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen")
type UserState struct { type UserState struct {
UpdateAt time.Time UpdateAt time.Time

2
shared/sm.go
View File

@ -28,7 +28,7 @@ func NewFsStateMachine(shardID uint64, replicaID uint64) sm.IStateMachine {
shardID: shardID, shardID: shardID,
replicaID: replicaID, replicaID: replicaID,
store: make(map[int64]*UserState), store: make(map[int64]*UserState),
// gdb: initalize.InitMysql("fusentest:XErSYmLELKMnf3Dh@tcp(110.41.19.98:3306)/fusentest"), // gdb: initalize.InitMysql("fsreaderwriter:XErSYmLELKMnf3Dh@tcp(fusen.cdmigcvz3rle.us-east-2.rds.amazonaws.com:3306)/fusen"),
} }
} }

8
utils/auth/cors.go
View File

@ -9,3 +9,11 @@ func FsCors(header http.Header) {
header.Set("Access-Control-Expose-Headers", "*") header.Set("Access-Control-Expose-Headers", "*")
header.Set("Access-Control-Allow-Credentials", "true") header.Set("Access-Control-Allow-Credentials", "true")
} }
func FsCorsResponse(w http.ResponseWriter) {
w.Header().Set("Access-Control-Allow-Origin", "*")
w.Header().Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
w.Header().Set("Access-Control-Allow-Headers", "*")
w.Header().Set("Access-Control-Expose-Headers", "*")
w.Header().Set("Access-Control-Allow-Credentials", "true")
}