support Queryx

README.md

@@ -27,6 +27,7 @@ All package run in no-cache mode.
 - [pgx](https://github.com/jackc/pgx)
 - [zorm](https://gitee.com/chunanyong/zorm)
 - [gen](https://gorm.io/gen/index.html)
+- [queryx](https://github.com/swiftcarrot/queryx)
 
 See [`go.mod`](go.mod) for their latest versions.
 

bench/models.go

@@ -215,6 +215,40 @@ func NewModel7() *Model7 {
 	return m
 }
 
+// Model for queryx
+type Model8 struct {
+	zorm.EntityStruct
+	ID      int    `column:"id"`
+	Name    string `column:"name"`
+	Title   string `column:"title"`
+	Fax     string `column:"fax"`
+	Web     string `column:"web"`
+	Age     int    `column:"age"`
+	Right   bool   `column:"\"right\""`
+	Counter int64  `column:"counter"`
+}
+
+func (entity *Model8) GetTableName() string {
+	return "models"
+}
+
+func (entity *Model8) GetPKColumnName() string {
+	return "id"
+}
+
+func NewModel8() *Model8 {
+	m := new(Model8)
+	m.Name = "Orm Benchmark"
+	m.Title = "Just a Benchmark for fun"
+	m.Fax = "99909990"
+	m.Web = "http://blog.milkpod29.me"
+	m.Age = 100
+	m.Right = true
+	m.Counter = 1000
+
+	return m
+}
+
 func NewReformModel() *r.ReformModels {
 	m := new(r.ReformModels)
 	m.Name = "Orm Benchmark"

bench/queryx.go

@@ -0,0 +1,137 @@
+package bench
+
+import (
+	"github.com/efectn/go-orm-benchmarks/bench/queryx/db/queryx"
+	"github.com/efectn/go-orm-benchmarks/helper"
+	"testing"
+
+	"github.com/efectn/go-orm-benchmarks/bench/queryx/db"
+	_ "github.com/lib/pq"
+)
+
+const (
+	queryxSelectMultiSQL = `SELECT * FROM models WHERE id > 0`
+)
+
+type Queryx struct {
+	helper.ORMInterface
+	client *db.QXClient
+}
+
+func CreateQueryx() helper.ORMInterface {
+	return &Queryx{}
+}
+
+func (q *Queryx) Name() string {
+	return "queryx"
+}
+
+func (q *Queryx) Init() error {
+	client, err := db.NewClient()
+	if err != nil {
+		return err
+	}
+	q.client = client
+	return err
+}
+
+func (q *Queryx) Close() error {
+	return nil
+}
+
+func (q *Queryx) Insert(b *testing.B) {
+	m := NewModel8()
+
+	b.ReportAllocs()
+	b.ResetTimer()
+
+	for i := 0; i < b.N; i++ {
+		m.ID = 0
+		_, err := q.client.QueryModel().Create(q.client.ChangeModel().SetName(m.Name).
+			SetTitle(m.Title).SetFax(m.Fax).SetWeb(m.Web).SetAge(int64(m.Age)).SetCounter(int32(m.Counter)).SetRight(true))
+		if err != nil {
+			helper.SetError(b, q.Name(), "Insert", err.Error())
+		}
+	}
+}
+
+func (q *Queryx) InsertMulti(b *testing.B) {
+	m := NewModel8()
+	ms := make([]*queryx.ModelChange, 0, 100)
+	for i := 0; i < 100; i++ {
+		ms = append(ms, q.client.ChangeModel().SetName(m.Name).
+			SetTitle(m.Title).SetFax(m.Fax).SetWeb(m.Web).SetAge(int64(m.Age)).SetCounter(int32(m.Counter)).SetRight(true))
+	}
+
+	b.ReportAllocs()
+	b.ResetTimer()
+
+	for i := 0; i < b.N; i++ {
+		_, err := q.client.QueryModel().InsertAll(ms)
+		if err != nil {
+			helper.SetError(b, q.Name(), "InsertMulti", err.Error())
+		}
+	}
+}
+
+func (q *Queryx) Update(b *testing.B) {
+	m := NewModel8()
+	change := q.client.ChangeModel().SetName(m.Name).SetRight(true).
+		SetTitle(m.Title).SetFax(m.Fax).SetWeb(m.Web).SetAge(int64(m.Age)).SetCounter(int32(m.Counter))
+	m8, err := q.client.QueryModel().Create(change)
+	if err != nil {
+		helper.SetError(b, q.Name(), "Update", err.Error())
+	}
+
+	b.ReportAllocs()
+	b.ResetTimer()
+
+	for i := 0; i < b.N; i++ {
+		_, err := q.client.QueryModel().Where(q.client.ModelID.EQ(m8.ID)).UpdateAll(change)
+		if err != nil {
+			helper.SetError(b, q.Name(), "Update", err.Error())
+		}
+	}
+}
+
+func (q *Queryx) Read(b *testing.B) {
+	m := NewModel8()
+	change := q.client.ChangeModel().SetName(m.Name).SetRight(true).
+		SetTitle(m.Title).SetFax(m.Fax).SetWeb(m.Web).SetAge(int64(m.Age)).SetCounter(int32(m.Counter))
+	_, err := q.client.QueryModel().Create(change)
+	if err != nil {
+		helper.SetError(b, q.Name(), "Read", err.Error())
+	}
+
+	b.ReportAllocs()
+	b.ResetTimer()
+
+	for i := 0; i < b.N; i++ {
+		_, err := q.client.QueryModel().FindBy(q.client.ModelName.EQ(m.Name))
+		if err != nil {
+			helper.SetError(b, q.Name(), "Read", err.Error())
+		}
+	}
+}
+
+func (q *Queryx) ReadSlice(b *testing.B) {
+	m := NewModel8()
+	change := q.client.ChangeModel().SetName(m.Name).SetRight(true).
+		SetTitle(m.Title).SetFax(m.Fax).SetWeb(m.Web).SetAge(int64(m.Age)).SetCounter(int32(m.Counter))
+	for i := 0; i < 100; i++ {
+		_, err := q.client.QueryModel().Create(change)
+		if err != nil {
+			helper.SetError(b, q.Name(), "ReadSlice", err.Error())
+		}
+	}
+
+	b.ReportAllocs()
+	b.ResetTimer()
+
+	for i := 0; i < b.N; i++ {
+		_, err := q.client.QueryModel().FindBySQL(queryxSelectMultiSQL)
+		if err != nil {
+			helper.SetError(b, q.Name(), "ReadSlice", err.Error())
+		}
+	}
+}