dbmysql.go
1.71 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
package mysql
import (
"HttpServer/conf"
"common/logger"
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
"strconv"
)
var (
m_game_db *sql.DB
)
func InitMysql() error {
db, err := InitMysqlByConf(conf.GetGameDBConf())
if err != nil {
return err
}
m_game_db = db
return nil
}
func InitMysqlByConf(cfg conf.MysqlConf) (*sql.DB, error) {
url := cfg.User + ":" + cfg.Pwd + "@tcp(" + cfg.Ip + ":" + strconv.Itoa(cfg.Port) + ")/" + cfg.Database + "?charset=utf8"
db, err := sql.Open("mysql", url)
if err != nil {
logger.Notic("Open mysql failed:%v url:%v", err, url)
return nil, err
}
return db, nil
}
func ExcuteCmd(cmd string) error {
rows, err := m_game_db.Query(cmd)
if rows != nil {
defer rows.Close()
}
if err != nil {
logger.Notic("ExcuteCmd Query error:%v cmd:%v", err, cmd)
return err
}
return err
}
func TestClearData(uid int) (int,error) {
cmd := fmt.Sprintf("select coin from b_user_ext_04 where user_id=%d", uid)
rows, err := m_game_db.Query(cmd)
if rows != nil {
defer rows.Close()
}
if err != nil {
logger.Notic("TestClearData mysql select error:%v", err)
return 0,err
}
var value int
for rows.Next() {
err = rows.Scan(&value)
if err != nil {
logger.Notic("TestClearData mysql handle result error:%v", err)
return 0,err
}
logger.Info("TestClearData coin=%v",value)
break
}
return value,nil
}
func DoClearData(uuid int) error{
//先删除十张分表的数据
for i:=0;i<10;i++ {
tablename := "b_base_data_0" + strconv.Itoa(i)
cmd := "DELETE from " + tablename + " where data_uid= " + strconv.Itoa(uuid)
err := ExcuteCmd(cmd)
if err != nil {
logger.Error("DoClearData err=%v,cmd=%v",err,cmd)
return err
}
}
return nil
}