diff --git a/src/HttpServer/logic/httpserver.go b/src/HttpServer/logic/httpserver.go index ef88c3a..5fe8ab8 100644 --- a/src/HttpServer/logic/httpserver.go +++ b/src/HttpServer/logic/httpserver.go @@ -37,6 +37,7 @@ func startServerHttpServe() { //------------------------------------------------------------- http.HandleFunc("/catcafe/ClearData", ClearData) //情况账号的测试接口 http.HandleFunc("/catcafe/AddWhiteList", AddWhiteList) //情况账号的测试接口 + http.HandleFunc("/catcafe/QueryAllAccount", QueryAllAccount) //查询所有账号的等级信息等数据 //------------------------------------------------------------- http.HandleFunc("/catcafe/login", UserLogin) //游客登录 http.HandleFunc("/catcafe/user/regeister", Regeister) //账号注册 @@ -71,6 +72,15 @@ func startServerHttpServe() { CheckErr(err) } +func QueryAllAccount(w http.ResponseWriter, r *http.Request) { + + logger.Info("QueryAllAccount ") + + + mysql.QueryAllData() +} + + func AddWhiteList(w http.ResponseWriter, r *http.Request) { query := r.URL.Query() @@ -86,8 +96,8 @@ func AddWhiteList(w http.ResponseWriter, r *http.Request) { if err!= nil { fmt.Fprint(w, "添加白名单失败,err=%v",err) }else { - fmt.Fprint(w, "添加白名单成功!") - } + fmt.Fprint(w, "添加白名单成功!") +} } diff --git a/src/mysql/dbmysql.go b/src/mysql/dbmysql.go index cdde904..0c479ee 100644 --- a/src/mysql/dbmysql.go +++ b/src/mysql/dbmysql.go @@ -2,10 +2,12 @@ package mysql import ( "HttpServer/conf" + "bufio" "common/logger" "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" + "os" "strconv" ) @@ -85,4 +87,58 @@ func DoClearData(uuid int) error{ } return nil +} + +func checkFileIsExist(filename string) bool { + var exist = true + if _, err := os.Stat(filename); os.IsNotExist(err) { + exist = false + } + return exist +} + +func QueryAllData() error{ + //先打开文件 + filename := "./data.txt" + var f *os.File +// var err1 error + if checkFileIsExist(filename) { //如果文件存在 + f, _ = os.OpenFile(filename, os.O_APPEND, 0666) //打开文件 + } else { + f, _ = os.Create(filename) //创建文件 + } + //先查询十张分表的数据 + for i:=0;i<10;i++ { + tablename := "b_base_data_0" + strconv.Itoa(i) + cmd := "SELECT user_id,lv,exp,login_time from " + tablename + rows, err := m_game_db.Query(cmd) + defer func() { + if rows != nil { + rows.Close() //可以关闭掉未scan连接一直占用 + } + }() + if err != nil { + logger.Error("Query failed,err:%v", err) + return err + } + for rows.Next() { + Uid := 0 + Ulv := 0 + Exp := 0 + LoginTime := 0 + err = rows.Scan(&Uid, &Ulv, &Exp,&LoginTime) //不scan会导致连接不释放 + if err != nil { + logger.Error("Scan failed,err:%v", err) + return err + } + + w := bufio.NewWriter(f) + + str := string(Uid) + " " + string(Ulv) + " " + string(Exp) + " " + string(LoginTime) + fmt.Fprintln(w, str) + w.Flush() + } + } + return nil + } \ No newline at end of file -- libgit2 0.21.0