kpt_xdmy/apiserver/routers/restful/test.go

package restful

import (
	"fmt"

	log "github.com/sirupsen/logrus"
	// "kpt.xdmy/apiserver/dao"
)

func Sqlx() {
	// st := time.Now()
	// rows, e := Dbs.Queryx("SELECT id,partcode FROM parts limit 3000")
	// rows, e := Dbs.Queryx("SELECT * FROM parts limit 3000")
	// rows, e := Dbs.Queryx("SELECT * FROM parts limit 3000")
	// dao.D.DB.Raw("SELECT id,partcode FROM parts limit 1000")
	// s.d.DB.Raw()
	// log.Printf("%d", time.Now().Sub(st).Milliseconds())
	// sql, e := Dbs.Beginx()
	// if e != nil {
	// 	log.Error(e)
	// }
	// _, e = sql.Exec("update pasture  set name =33 where name  ='22'")
	// if e != nil {
	// 	log.Error(e)
	// }
	// sql.Commit()
	// var name string
	var sqls, param string
	tx, e := Dbs.Beginx()
	if e != nil {
		log.Error(e)
	}
	rows, e := tx.Queryx("SELECT sqlstr,params FROM apisql WHERE sqlname = ? AND ENABLE>0 ", "getBigPartTransferList")
	// rows, e := Dbs.Queryx("select id from parts where createTime is not null   limit 10 ")
	// rows, e := Dbs.NamedQuery("select name  from  pasture  where  name=:name", map[string]interface{}{"name": "33"})
	if e != nil {
		fmt.Print(e)
	}
	if rows.Next() {
		rows.Scan(&sqls, &param)
	}
	// tx.Commit()
	fmt.Println(sqls, param)
	// for rows.Next() {
	// 	var value string
	// 	rs, err := rows.SliceScan()
	// 	if err != nil {
	// 		fmt.Printf("BigpartUse SliceScan: %v", err)
	// 	}
	// 	for _, r := range rs {

	// 		switch r.(type) {
	// 		case []uint8:
	// 			value = string(r.([]uint8))
	// 		case int64:
	// 			value = strconv.FormatInt(r.(int64), 10)
	// 		case time.Time:
	// 			value = r.(time.Time).Format("2006-01-02 15:04:05")
	// 		}
	// 		fmt.Println(value)
	// 	}
	// }

	// rows.Scan(&name)
	// fmt.Printf("name = %s  \n", name)
	// var ids int
	// var partcode string
	// p := make(map[string]interface{})
	// in := make([]string, 0)

	// rows.Next()
	// rows.Scan(&ids, &partcode)

	// fmt.Printf("id: %d, code: %s\n", ids, partcode)

	// rows.Next()
	// rows.MapScan(p)
	// fmt.Printf("map: %s\n", p)

	// rows.Next()
	// rows.Scan(&in)
	// fmt.Printf("interface: %s\n", in)

	// rows.Next()
	// sl, e := rows.SliceScan()
	// if e != nil {
	// 	fmt.Println(e)
	// }
	// fmt.Printf("slice: %s\n", sl)
	defer rows.Close()
}