diff --git a/aufs/core/setting.go b/aufs/core/setting.go index df0e659..012b6a6 100644 --- a/aufs/core/setting.go +++ b/aufs/core/setting.go @@ -3,10 +3,7 @@ package core import ( "aufs/db" "encoding/json" - "fmt" "net/http" - // "github.com/jmoiron/sqlx" - // _ "github.com/logoove/sqlite" ) // 输出的结构 @@ -14,39 +11,18 @@ type ScJson struct { Message string `json:"message"` Status int `json:"status"` Data []db.StServerInfo `json:"data"` - // Data *db.StServerInfo `json:"data"` } // 系统设置 func Settdb(w http.ResponseWriter, r *http.Request) { - // 检查数据表是否存在 - // scdb, err := sqlx.Open("sqlite", "ups.db") - // if err != nil { - // fmt.Printf("Failed to open database: %v\n", err) - // return - // } - // defer scdb.Close() - // 如果表sc_server不存在,则创建 - // _, err = scdb.Exec("SELECT name FROM sqlite_master WHERE type='table' AND name='sc_server'") - // if err != nil { - // // cuowu - // log.Fatalf("table has exists:%s", err) - // } - // + // 数据库初始化 db.Init() sclst := db.GetlScList() - // var sclst *db.StServerInfo - - // sclst, err := db.GetServerInfo("1") - // if err != nil { - // fmt.Printf("获取服务器信息失败: %v\n", err) - // return - // } // 打印查询结果 - for _, sc := range sclst { - fmt.Printf("ID: %s, Name: %s, Addr: %s, Port: %s, Token: %s\n", sc.Id, sc.Scname, sc.Addr, sc.Port, sc.Token) - } + // for _, sc := range sclst { + // fmt.Printf(&sc.Id, &sc.Scname, &sc.Addr, &sc.Port, &sc.Token, &sc.Status) + // } // scresp := ScJson{ diff --git a/aufs/db/servDb.go b/aufs/db/servDb.go index 9f1e776..e0f2ecc 100644 --- a/aufs/db/servDb.go +++ b/aufs/db/servDb.go @@ -45,7 +45,7 @@ func GetlScList() (sclist []StServerInfo) { sclist = make([]StServerInfo, 0) // 查询语句 - rows, err := db.Query("SELECT id,scname,addr,port,token FROM sc_server") + rows, err := db.Query("SELECT * FROM sc_server") // if err != nil { @@ -57,7 +57,7 @@ func GetlScList() (sclist []StServerInfo) { // var weight float64 var info StServerInfo //将赋值到对应的字段上 - err = rows.Scan(&info.Id, &info.Addr, &info.Port, &info.Token) + err = rows.Scan(&info.Id, &info.Scname, &info.Addr, &info.Port, &info.Token, &info.Status) if err != nil { fmt.Printf("Failed to read data: %v\n", err) @@ -81,7 +81,7 @@ func GetServerInfo(id string) (*StServerInfo, error) { // 定义一个结构体变量 var info StServerInfo // 扫描查询结果 - err = row.Scan(&info.Id, &info.Addr, &info.Port, &info.Token) + err = row.Scan(&info.Id, &info.Scname, &info.Addr, &info.Port, &info.Token, &info.Status) if err != nil { return nil, err }