|
|
|
@ -1,6 +1,9 @@ |
|
|
|
package db |
|
|
|
|
|
|
|
import "fmt" |
|
|
|
import ( |
|
|
|
"fmt" |
|
|
|
"log" |
|
|
|
) |
|
|
|
|
|
|
|
// 创建服务器数据库
|
|
|
|
func CreateScdb() { |
|
|
|
@ -23,7 +26,7 @@ func CreateScdb() { |
|
|
|
fmt.Printf("Successfully created database table! \n") |
|
|
|
} |
|
|
|
|
|
|
|
//记录服务器的信息
|
|
|
|
// 记录服务器的信息
|
|
|
|
func AddServerInfo(info *StServerInfo) error { |
|
|
|
// 插入语句
|
|
|
|
stmt, err := db.Prepare("INSERT INTO s_info (id, addr, port, token) VALUES (?, ?, ?, ?)") |
|
|
|
@ -89,18 +92,23 @@ func GetServerInfo(id int16) StServerInfo { |
|
|
|
} |
|
|
|
|
|
|
|
// 更新服务器信息
|
|
|
|
func UpdateServerInfo(info StServerInfo) { |
|
|
|
func UpdateServerInfo(info StServerInfo) int { |
|
|
|
// 更新语句
|
|
|
|
stmt, err := db.Prepare("UPDATE s_info SET addr = ?, port = ?, token = ? WHERE id = ?") |
|
|
|
stmt, err := db.Prepare("UPDATE sc_server SET scname = ?, addr = ?, port = ?, token = ?, status = ? WHERE id = ?") |
|
|
|
if err != nil { |
|
|
|
panic(err) |
|
|
|
// panic(err)
|
|
|
|
log.Fatalf("UpdateServerInfo: %s", err) |
|
|
|
// return 0
|
|
|
|
} |
|
|
|
defer stmt.Close() |
|
|
|
// 执行更新语句
|
|
|
|
_, err = stmt.Exec(info.Addr, info.Port, info.Token, info.Id) |
|
|
|
_, err = stmt.Exec(info.Scname, info.Addr, info.Port, info.Token, info.Status, info.Id) |
|
|
|
if err != nil { |
|
|
|
panic(err) |
|
|
|
// panic(err)
|
|
|
|
log.Fatalf("UpdateServerInfo: %s", err) |
|
|
|
// return 0
|
|
|
|
} |
|
|
|
return 1 |
|
|
|
} |
|
|
|
|
|
|
|
// 删除服务器信息
|
|
|
|
|