3
0

upd(vendor): update database profiler

This commit is contained in:
Tit Petric
2018-07-17 12:05:16 +02:00
parent e9a3d51cfa
commit ea03b5a1ec
2 changed files with 31 additions and 10 deletions
Generated
+1 -1
View File
@@ -93,7 +93,7 @@
".",
"resputil"
]
revision = "b45ac8b1bb2f1a2fccd1530abb5f44f5f0de67f8"
revision = "48ba0357b31ad368f66fa2441bd23c12757c56a0"
[[projects]]
branch = "master"
+30 -9
View File
@@ -218,22 +218,43 @@ func (r *DB) set(data interface{}) string {
}
// Replace is a helper function which will issue an `replace` statement to the database
func (r *DB) Replace(table string, data interface{}) error {
sql := "replace into " + table + " set " + r.set(data)
_, err := r.NamedExec(sql, data)
func (r *DB) Replace(table string, args interface{}) error {
var err error
query := "replace into " + table + " set " + r.set(args)
if r.Profiler != nil {
ctx := DatabaseProfilerContext{}.new(query, args)
_, err = r.NamedExec(query, args)
r.Profiler.Post(ctx)
} else {
_, err = r.NamedExec(query, args)
}
return err
}
// Insert is a helper function which will issue an `insert` statement to the database
func (r *DB) Insert(table string, data interface{}) error {
sql := "insert into " + table + " set " + r.set(data)
_, err := r.NamedExec(sql, data)
func (r *DB) Insert(table string, args interface{}) error {
var err error
query := "insert into " + table + " set " + r.set(args)
if r.Profiler != nil {
ctx := DatabaseProfilerContext{}.new(query, args)
_, err = r.NamedExec(query, args)
r.Profiler.Post(ctx)
} else {
_, err = r.NamedExec(query, args)
}
return err
}
// InsertIgnore is a helper function which will issue an `insert ignore` statement to the database
func (r *DB) InsertIgnore(table string, data interface{}) error {
sql := "insert ignore into " + table + " set " + r.set(data)
_, err := r.NamedExec(sql, data)
func (r *DB) InsertIgnore(table string, args interface{}) error {
var err error
query := "insert ignore into " + table + " set " + r.set(args)
if r.Profiler != nil {
ctx := DatabaseProfilerContext{}.new(query, args)
_, err = r.NamedExec(query, args)
r.Profiler.Post(ctx)
} else {
_, err = r.NamedExec(query, args)
}
return err
}