add bookstore example

example/bookstore/rpc/model/book.sql

@@ -0,0 +1,6 @@
+CREATE TABLE `book`
+(
+  `book` varchar(255) NOT NULL COMMENT 'book name',
+  `price` int NOT NULL COMMENT 'book price',
+  PRIMARY KEY(`book`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

example/bookstore/rpc/model/bookmodel.go

@@ -0,0 +1,82 @@
+package model
+
+import (
+	"database/sql"
+	"fmt"
+	"strings"
+
+	"github.com/tal-tech/go-zero/core/stores/cache"
+	"github.com/tal-tech/go-zero/core/stores/sqlc"
+	"github.com/tal-tech/go-zero/core/stores/sqlx"
+	"github.com/tal-tech/go-zero/core/stringx"
+	"github.com/tal-tech/go-zero/tools/goctl/model/sql/builderx"
+)
+
+var (
+	bookFieldNames          = builderx.FieldNames(&Book{})
+	bookRows                = strings.Join(bookFieldNames, ",")
+	bookRowsExpectAutoSet   = strings.Join(stringx.Remove(bookFieldNames, "create_time", "update_time"), ",")
+	bookRowsWithPlaceHolder = strings.Join(stringx.Remove(bookFieldNames, "book", "create_time", "update_time"), "=?,") + "=?"
+
+	cacheBookBookPrefix = "cache#Book#book#"
+)
+
+type (
+	BookModel struct {
+		sqlc.CachedConn
+		table string
+	}
+
+	Book struct {
+		Book  string `db:"book"`  // book name
+		Price int64  `db:"price"` // book price
+	}
+)
+
+func NewBookModel(conn sqlx.SqlConn, c cache.CacheConf, table string) *BookModel {
+	return &BookModel{
+		CachedConn: sqlc.NewConn(conn, c),
+		table:      table,
+	}
+}
+
+func (m *BookModel) Insert(data Book) (sql.Result, error) {
+	query := `insert into ` + m.table + ` (` + bookRowsExpectAutoSet + `) values (?, ?)`
+	return m.ExecNoCache(query, data.Book, data.Price)
+}
+
+func (m *BookModel) FindOne(book string) (*Book, error) {
+	bookBookKey := fmt.Sprintf("%s%v", cacheBookBookPrefix, book)
+	var resp Book
+	err := m.QueryRow(&resp, bookBookKey, func(conn sqlx.SqlConn, v interface{}) error {
+		query := `select ` + bookRows + ` from ` + m.table + ` where book = ? limit 1`
+		return conn.QueryRow(v, query, book)
+	})
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}
+}
+
+func (m *BookModel) Update(data Book) error {
+	bookBookKey := fmt.Sprintf("%s%v", cacheBookBookPrefix, data.Book)
+	_, err := m.Exec(func(conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := `update ` + m.table + ` set ` + bookRowsWithPlaceHolder + ` where book = ?`
+		return conn.Exec(query, data.Price, data.Book)
+	}, bookBookKey)
+	return err
+}
+
+func (m *BookModel) Delete(book string) error {
+
+	bookBookKey := fmt.Sprintf("%s%v", cacheBookBookPrefix, book)
+	_, err := m.Exec(func(conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := `delete from ` + m.table + ` where book = ?`
+		return conn.Exec(query, book)
+	}, bookBookKey)
+	return err
+}

example/bookstore/rpc/model/vars.go

@@ -0,0 +1,5 @@
+package model
+
+import "github.com/tal-tech/go-zero/core/stores/sqlx"
+
+var ErrNotFound = sqlx.ErrNotFound