Browse Source

修改查询

master
xyiege 5 months ago
parent
commit
eb2e203ebb
  1. 6
      aufs/core/setting.go
  2. 9
      aufs/db/servDb.go
  3. 1
      aufs/db/sqliteDb.go
  4. BIN
      aufs/ups.db

6
aufs/core/setting.go

@ -3,6 +3,7 @@ package core
import (
"aufs/db"
"encoding/json"
"fmt"
"net/http"
// "github.com/jmoiron/sqlx"
// _ "github.com/logoove/sqlite"
@ -32,6 +33,11 @@ func Settdb(w http.ResponseWriter, r *http.Request) {
// }
//
sclst := db.GetlScList()
// 打印查询结果
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)
}
//
scresp := ScJson{
Message: "success",

9
aufs/db/servDb.go

@ -45,7 +45,8 @@ func GetlScList() (sclist []StServerInfo) {
sclist = make([]StServerInfo, 0)
// 查询语句
rows, err := db.Query("SELECT * FROM sc_server")
rows, err := db.Query("SELECT id,scname,addr,port,token FROM sc_server")
//
if err != nil {
fmt.Printf("Failed to query data: %v\n", err)
@ -54,15 +55,15 @@ func GetlScList() (sclist []StServerInfo) {
// FOR loop
for rows.Next() {
// var weight float64
var st StServerInfo
var info StServerInfo
//将赋值到对应的字段上
err = rows.Scan(&st.Id, &st.Port, &st.Scname, &st.Status, &st.Token)
err = rows.Scan(&info.Id, &info.Addr, &info.Port, &info.Token)
if err != nil {
fmt.Printf("Failed to read data: %v\n", err)
continue
}
sclist = append(sclist, st)
sclist = append(sclist, info)
}
return sclist
}

1
aufs/db/sqliteDb.go

@ -47,6 +47,7 @@ func CreateTable() {
id INTEGER PRIMARY KEY NOT NULL,
fname TEXT NOT NULL,
fpath TEXT NOT NULL,
fpbs TEXT NOT NULL,
fhash TEXT NOT NULL
);`

BIN
aufs/ups.db

Binary file not shown.
Loading…
Cancel
Save