-
Notifications
You must be signed in to change notification settings - Fork 0
/
dba.go
105 lines (77 loc) · 1.82 KB
/
dba.go
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
package main
import "fmt"
import "database/sql"
import _ "github.com/mattn/go-sqlite3"
import "io/ioutil"
import "os"
func Dbafc(argm []string) {
var err error
db, err := sql.Open("sqlite3", "file:weibopulldb.sqlite")
if err != nil {
fmt.Println(err)
}
defer db.Close()
switch argm[0] {
case "ExecRawSql", "ERS", "ers":
if len(argm) < 2 {
fmt.Println("assert fail: Arg len")
return
}
fd, err := os.Open(argm[1])
defer fd.Close()
if err != nil {
fmt.Println(err)
}
ftx, err := ioutil.ReadAll(fd)
if err != nil {
fmt.Println(err)
}
execsql := string(ftx)
transaction, _ := db.Begin()
res, err := transaction.Exec(execsql)
if err != nil {
fmt.Println(err)
ir, _ := res.RowsAffected()
err = transaction.Rollback()
if err != nil {
fmt.Println(err)
} else {
fmt.Println("Rollbacked SUCCESSFULLY.")
}
fmt.Printf("%v Rows was Affected, HOWEVER tx was rollbacked as an error was throwen.", ir)
}
ir, _ := res.RowsAffected()
err = transaction.Commit()
if err != nil {
fmt.Println(err)
} else {
fmt.Println("Commited SUCCESSFULLY.")
}
fmt.Printf("%v Rows was Affected.", ir)
case "SetConf", "SF", "sf":
if len(argm) < 3 {
fmt.Println("assert fail: Arg len")
return
}
_, err := db.Exec("DELETE FROM programma_configure WHERE confname=?;", argm[1])
if err != nil {
fmt.Println(err)
}
_, err = db.Exec("INSERT INTO programma_configure(confname,cfncval) VALUES (?,?)", argm[1], argm[2])
if err != nil {
fmt.Println(err)
}
case "CatConf", "CF", "cf":
if len(argm) < 2 {
fmt.Println("assert fail: Arg len")
return
}
row := db.QueryRow("SELECT cfncval FROM programma_configure WHERE confname=?", argm[1])
var tocat string
err := row.Scan(&tocat)
if err != nil {
fmt.Println(err)
}
fmt.Println(tocat)
}
}