Browse Source

修改服务器查询

master
xyiege 10 months ago
parent
commit
92a7492073
  1. 50
      aufs/core/setting.go
  2. 2
      aufs/db/servDb.go

50
aufs/core/setting.go

@ -3,12 +3,9 @@ package core
import ( import (
"aufs/db" "aufs/db"
"encoding/json" "encoding/json"
"fmt"
"log"
"net/http" "net/http"
// "github.com/jmoiron/sqlx"
"github.com/jmoiron/sqlx" // _ "github.com/logoove/sqlite"
_ "github.com/logoove/sqlite"
) )
// 输出的结构 // 输出的结构
@ -21,19 +18,19 @@ type ScJson struct {
// 系统设置 // 系统设置
func Settdb(w http.ResponseWriter, r *http.Request) { func Settdb(w http.ResponseWriter, r *http.Request) {
// 检查数据表是否存在 // 检查数据表是否存在
scdb, err := sqlx.Open("sqlite", "./ups.db") // scdb, err := sqlx.Open("sqlite", "ups.db")
if err != nil { // if err != nil {
fmt.Printf("Failed to open database: %v\n", err) // fmt.Printf("Failed to open database: %v\n", err)
return // return
} // }
defer scdb.Close() // defer scdb.Close()
// 如果表sc_server不存在,则创建 // 如果表sc_server不存在,则创建
_, err = scdb.Exec("SELECT name FROM sqlite_master WHERE type='table' AND name='sc_server'") // _, err = scdb.Exec("SELECT name FROM sqlite_master WHERE type='table' AND name='sc_server'")
if err != nil { // if err != nil {
// cuowu // // cuowu
log.Fatalf("table has exists:%s", err) // log.Fatalf("table has exists:%s", err)
} // }
//如果表存在 //
sclst := db.GetlScList() sclst := db.GetlScList()
// //
scresp := ScJson{ scresp := ScJson{
@ -43,23 +40,4 @@ func Settdb(w http.ResponseWriter, r *http.Request) {
} }
uCorsHadler(w, r) uCorsHadler(w, r)
json.NewEncoder(w).Encode(scresp) json.NewEncoder(w).Encode(scresp)
// 表不存在,创建表
// sts := `
// CREATE TABLE IF NOT EXISTS sc_server (
// id INTEGER PRIMARY KEY NOT NULL,
// scname TEXT NOT NULL,
// addr TEXT NOT NULL,
// port TEXT NOT NULL,
// token TEXT NOT NULL,
// status INTEGER NOT NULL
// );`
// 执行建表语句
// _, err = scdb.Exec(sts)
// if err != nil {
// fmt.Printf("Failed to create database table: %v\n", err)
// return
// }
// fmt.Printf("Successfully created database table! \n")
} }

2
aufs/db/servDb.go

@ -45,7 +45,7 @@ func GetlScList() (sclist []StServerInfo) {
sclist = make([]StServerInfo, 0) sclist = make([]StServerInfo, 0)
// 查询语句 // 查询语句
rows, err := db.Query("SELECT * FROM f_info WHERE fpbs = ?") rows, err := db.Query("SELECT * FROM sc_server")
// //
if err != nil { if err != nil {
fmt.Printf("Failed to query data: %v\n", err) fmt.Printf("Failed to query data: %v\n", err)

Loading…
Cancel
Save