new

Author: fizzday

examples/demo.go

@@ -2,10 +2,32 @@ package main
 
 import (
 	"fmt"
-	"github.com/gohouse/gorose"
-	_ "github.com/gohouse/gorose/driver/mysql"
+	_ "github.com/go-sql-driver/mysql"
+	"github.com/gohouse/gorose/examples/config"
+	"github.com/gohouse/gorose/utils"
 )
 
 func main() {
-	fmt.Println(gorose.VERSION)
+	connection := config.GetConnection()
+	connection.DbConfig.Master.EnableQueryLog = true
+	// close DB
+	defer connection.Close()
+
+	db := connection.NewSession()
+	res, err := db.Table("gp_user").Get()
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	for _,item := range res {
+		//fmt.Println(item)
+		//return
+		db2 := connection.NewSession()
+		res,err:=db2.Table("gp_user").Where("Id",item["Id"]).Data(map[string]interface{}{
+			"Utm": fmt.Sprintf("%s%v",utils.GetRandomAlarm(2),utils.GetRandomNum(4)),
+		}).Update()
+		//fmt.Println(db2.LastSql)
+		fmt.Println(res,err)
+		//return
+	}
 }

examples/execute.go

@@ -7,15 +7,26 @@ import (
 )
 
 func main() {
-	db := config.GetConnection()
+	connection := config.GetConnection()
 	// close DB
-	defer db.Close()
+	defer connection.Close()
+
+	db := connection.NewSession()
+
+	user, err := db.Execute("update users set job=? where id = ?", "it",55)
+	//user, err := db.Query("select * from users where id > ? limit 1", 1)
 
-	user, err := db.Execute("update users set name=? where id=?", "fizz8", 4)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
 
+	fmt.Println(db.LastSql)
 	fmt.Println(user)
+
+	// return json
+	//res2 := user.Limit(2).Get()
+	//fmt.Println(db.LastSql())
+	//fmt.Println(user)
+
 }

examples/mysql.go

@@ -12,30 +12,20 @@ func main() {
 	defer connection.Close()
 
 	db := connection.NewSession()
-	fmt.Println(db)
-	res, err := db.Table("users").Where("aid",  1545).Count()
-	if err != nil {
-		fmt.Println(err)
-		return
-	}
-	//fmt.Println(len(res))
-	fmt.Println(db.LastSql)
-	fmt.Println(res)
-
 	var db2 = connection.NewSession()
-	res2, err := db2.Table("users").Limit(2).Get()
+	res2, err := db2.Table("users").Fields("id").Limit(2).Get()
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
 	fmt.Println(res2)
 	fmt.Println(db.JsonEncode(res2))
 
-	//============== result ======================
-
-	//SELECT * FROM users WHERE  id > '2' LIMIT 1
-	//map[id:3 name:gorose age:18 website:go-rose.com job:go orm]
-	//SELECT * FROM users LIMIT 2
-	//[map[id:1 name:fizz age:18 website:fizzday.net job:it] map[id:2 name:fizzday age:18 website:fizzday.net job:engineer]]
-
+	var db3 = connection.NewSession()
+	res3,err := db3.Table("users").Fields("id,age,job").
+		//Where("id", "in", []interface{}{1,55}).
+		Where([][]interface{}{{"id", "in", []interface{}{1, 55}}}).
+		Get()
+	fmt.Println(db3.LastSql)
+	fmt.Println(db.JsonEncode(res3))
 }

parser/json_parser.go

@@ -2,7 +2,6 @@ package parser
 
 import (
 	"encoding/json"
-	"fmt"
 	"io/ioutil"
 	"reflect"
 	"strings"
@@ -40,7 +39,7 @@ func (c *JsonConfigParser) Parse(file string, dbConfCluster interface{}) (err er
 
 func jsonDecoder(str []byte, dbConfCluster interface{}) (err error) {
 	srcElem := reflect.Indirect(reflect.ValueOf(dbConfCluster))
-	fmt.Println(srcElem)
+	//fmt.Println(srcElem)
 	fieldType := srcElem.FieldByName("Master").Type().Elem()
 	fieldElem := reflect.New(fieldType)
 	err = json.Unmarshal(str, fieldElem.Interface())

utils/util.go

@@ -1,6 +1,7 @@
 package utils
 
 import (
+	"crypto/md5"
 	"encoding/json"
 	"log"
 	"math"
@@ -496,21 +497,37 @@ func StrutForScan(u interface{}) []interface{} {
 	return v
 }
 
+func GetRandomAlarm(l int) string {
+	if l<=0 {
+		return ""
+	}
+	str := "abcdefghijkmnpqrstuvwxyz"
+	myBytes := []byte(str)
+	myBytesLen := len(myBytes)
+	result := []byte{}
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
+	for i := 0; i < l; i++ {
+		result = append(result, myBytes[r.Intn(myBytesLen)])
+	}
+	return string(result)
+}
+
 func GetRandomString(l int) string {
+	if l<=0 {
+		return ""
+	}
 	str := "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
 	myBytes := []byte(str)
+	myBytesLen := len(myBytes)
 	result := []byte{}
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	for i := 0; i < l; i++ {
-		result = append(result, myBytes[r.Intn(len(myBytes))])
+		result = append(result, myBytes[r.Intn(myBytesLen)])
 	}
 	return string(result)
 }
 
 func GetRandomNum(l int) int {
-	//str := "123456789"
-	//str := "0123456789"
-	//myBytes := []byte(str)
 	var result []int
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 
@@ -531,6 +548,25 @@ func GetRandomNum(l int) int {
 	return tmp
 }
 
+func GetOrderNO() string {
+	rand.Seed(time.Now().UnixNano()) //利用当前时间的UNIX时间戳初始化rand包
+	var suffix string
+	for i := 0; i < 6; i++ {
+		x := rand.Intn(10)
+		suffix += strconv.Itoa(x)
+	}
+
+	return fmt.Sprintf("%v%v",time.Now().UnixNano(),suffix)
+}
+
+func Md5(str interface{}) string {
+	data := []byte(fmt.Sprintf("%v", str))
+	has := md5.Sum(data)
+	md5str := fmt.Sprintf("%x", has) //将[]byte转成16进制
+
+	return md5str
+}
+
 type DateTime struct {
 	LastMonthStart string
 	LastMonthEnd   string