From 6fab9389228164ce780c2aea2407a2723e87777b Mon Sep 17 00:00:00 2001 From: John Date: Wed, 11 Apr 2018 17:57:54 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dgdb=E6=9D=A1=E4=BB=B6?= =?UTF-8?q?=E5=8F=82=E6=95=B0=E8=BD=AC=E5=AD=97=E7=AC=A6=E4=B8=B2=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- g/database/gdb/gdb_base.go | 9 ++------- geg/database/mysql/mysql.go | 36 ++++++++++++++++++------------------ 2 files changed, 20 insertions(+), 25 deletions(-) diff --git a/g/database/gdb/gdb_base.go b/g/database/gdb/gdb_base.go index a0d8bc21c..bc5e8c615 100644 --- a/g/database/gdb/gdb_base.go +++ b/g/database/gdb/gdb_base.go @@ -12,6 +12,7 @@ import ( "errors" "strings" "database/sql" + "gitee.com/johng/gf/g/util/gconv" ) // 关闭链接 @@ -309,13 +310,7 @@ func (db *Db) Update(table string, data interface{}, condition interface{}, args return nil, errors.New("invalid data type for 'data' field, string or Map expected") } for _, v := range args { - if r, ok := v.(string); ok { - params = append(params, r) - } else if r, ok := v.(int); ok { - params = append(params, string(r)) - } else { - - } + params = append(params, gconv.String(v)) } return db.Exec(fmt.Sprintf("UPDATE %s%s%s SET %s WHERE %s", db.charl, table, db.charr, updates, condition), params...) } diff --git a/geg/database/mysql/mysql.go b/geg/database/mysql/mysql.go index 2ea305c66..6e18879a5 100644 --- a/geg/database/mysql/mysql.go +++ b/geg/database/mysql/mysql.go @@ -16,7 +16,7 @@ func init () { Host : "127.0.0.1", Port : "3306", User : "root", - Pass : "8692651", + Pass : "123456", Name : "test", Type : "mysql", Role : "master", @@ -225,7 +225,7 @@ func update1() { // 数据更新 func update2() { fmt.Println("update2:") - r, err := db.Update("user", "name='john2'", "uid=1") + r, err := db.Update("user", gdb.Map{"name" : "john6"}, "uid=?", 1) if err == nil { fmt.Println(r.LastInsertId()) fmt.Println(r.RowsAffected()) @@ -300,7 +300,7 @@ func linkopUpdate1() { // 通过Map指针方式传参方式 func linkopUpdate2() { fmt.Println("linkopUpdate2:") - r, err := db.Table("user").Data(gdb.Map{"name" : "john2"}).Where("name=?", "john").Update() + r, err := db.Table("user").Data(gdb.Map{"name" : "john2"}).Where("name=?", "john_1").Update() if err == nil { fmt.Println(r.RowsAffected()) } else { @@ -438,22 +438,22 @@ func instance() { func main() { - create() - create() - insert() - query() - replace() - save() - batchInsert() - update1() + //create() + //create() + //insert() + //query() + //replace() + //save() + //batchInsert() + //update1() update2() - update3() - linkopSelect1() - linkopSelect2() - linkopSelect3() - linkopUpdate1() - linkopUpdate2() - linkopUpdate3() + //update3() + //linkopSelect1() + //linkopSelect2() + //linkopSelect3() + //linkopUpdate1() + //linkopUpdate2() + //linkopUpdate3() //keepPing() //transaction1() //transaction2()