sqlca

package module
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2020 License: MIT Imports: 18 Imported by: 1

README

author

lory.li

email

civet148@126.com

QQ

93864947

sqlca

a enhancement database and cache tool based on sqlx and redigogo which based on redigo and go-redis-cluster

database schema

/*
SQLyog Ultimate v13.1.1 (64 bit)
MySQL - 8.0.18 : Database - test
*********************************************************************
*/

/*!40101 SET NAMES utf8 */;

/*!40101 SET SQL_MODE=''*/;

/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;

USE `test`;

/*Table structure for table `classes` */

DROP TABLE IF EXISTS `classes`;

CREATE TABLE `classes` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'incr id',
  `class_no` varchar(16) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '' COMMENT 'class no',
  `user_id` int(11) NOT NULL COMMENT 'student id',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'update time',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;

/*Data for the table `classes` */

insert  into `classes`(`id`,`class_no`,`user_id`,`created_at`,`updated_at`) values 
(1,'S-01',3,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(2,'S-01',4,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(3,'S-01',5,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(4,'S-01',6,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(5,'S-02',7,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(6,'S-02',8,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(7,'S-02',9,'2020-04-10 10:08:08','2020-04-10 10:08:08'),
(8,'S-02',10,'2020-04-10 10:08:08','2020-04-10 10:08:08');

/*Table structure for table `users` */

DROP TABLE IF EXISTS `users`;

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'auto inc id',
  `name` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '' COMMENT 'user name',
  `phone` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'phone number',
  `sex` tinyint(1) NOT NULL DEFAULT '1' COMMENT 'user sex',
  `email` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '' COMMENT 'email',
  `disable` tinyint(1) NOT NULL DEFAULT '0' COMMENT 'disabled(0=false 1=true)',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT 'create time',
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT 'update time',
  PRIMARY KEY (`id`) USING BTREE,
  KEY `phone` (`phone`)
) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;

/*Data for the table `users` */

insert  into `users`(`id`,`name`,`phone`,`sex`,`email`,`disable`,`created_at`,`updated_at`) values 
(1,'lory','8618688888888',2,'2822922@qq.com',0,'2020-03-11 08:46:57','2020-04-13 12:23:34'),
(2,'lucas','8618699999999',1,'john@gmail.com',0,'2020-03-11 08:46:57','2020-03-11 16:02:51'),
(3,'std00','8618600000000',1,'admin@golang.org',1,'2020-03-11 14:42:53','2020-04-13 12:09:50'),
(4,'std01','8618600000001',1,'user1@hotmail.com',0,'2020-03-11 16:58:45','2020-04-10 10:07:15'),
(5,'std02','8618600000002',1,'user2@hotmail.com',0,'2020-03-11 16:58:45','2020-04-10 10:07:20'),
(6,'std03','8618600000003',1,'user1@hotmail.com',0,'2020-03-11 16:59:58','2020-04-10 10:07:22'),
(7,'std04','8618600000004',1,'user2@hotmail.com',0,'2020-03-11 16:59:58','2020-04-10 10:07:26'),
(9,'std05','8618600000005',1,'user1@hotmail.com',0,'2020-03-11 17:03:51','2020-04-10 10:07:28'),
(10,'std06','8618600000006',1,'user2@hotmail.com',0,'2020-03-11 17:03:51','2020-04-10 10:07:29'),
(11,'std07','8618600000007',1,'user1@hotmail.com',0,'2020-03-11 17:04:17','2020-04-10 10:07:31'),
(12,'std08','8618600000008',2,'user2@hotmail.com',0,'2020-03-11 17:04:17','2020-04-10 10:07:33'),
(13,'std09','8618600000009',1,'user3@hotmail.com',0,'2020-03-11 17:04:49','2020-04-10 10:07:35'),
(14,'std10','8618600000010',2,'user4@hotmail.com',0,'2020-03-11 17:04:49','2020-04-10 10:07:38');

/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

data model

type UserDO struct {
    Id    int32  `db:"id"`  
    Name  string `db:"name"`  
    Phone string `db:"phone"` 
    Sex   int8   `db:"sex"`   
    Email string `db:"email"` 
    Disable int8 `db:"disable"`
}

open database/redis


e := sqlca.NewEngine()
e.Debug(true) //debug mode on

// open database driver (requred)
e.Open("mysql://root:123456@127.0.0.1:3306/test?charset=utf8mb4")

// open redis driver for cache (optional)
e.Open("redis://127.0.0.1:6379/cluster?db=0", 3600) //redis standalone mode

global variants

const (
	TABLE_NAME_USERS = "users"
)

orm: insert/upsert from data model

user := UserDO{
        Name:  "admin",
        Phone: "8618600000000",
        Sex:   1,
        Email: "admin@golang.org",
}

e.Model(&user).Table(TABLE_NAME_USERS).Insert()

user := UserDO{
    Id:    1,
    Name:  "lory",
    Phone: "8618688888888",
    Sex:   2,
    Email: "lory@gmail.com",
}

e.Model(&user).Table(TABLE_NAME_USERS).Select("name", "phone", "email", "sex").Upsert()

orm: update from data model

user := UserDO{
    Name:  "john",
    Phone: "8618699999999",
    Sex:   1,
    Email: "john@gmail.com",
}

e.Model(&user).Table(TABLE_NAME_USERS).Id(1).Select("name", "phone", "email", "sex").Update()

orm: query results into data model

user := UserDO{}

// default 'select * from ...'
e.Model(&user).Table(TABLE_NAME_USERS).Id(1).Query()

// just select 'name' and 'phone' 
e.Model(&user).Table(TABLE_NAME_USERS).Id(1).Select("name", "phone").Query()

orm: query results into data model slice

var users []UserDO

// select id, name, phone from users limit 3
//e.Model(&user).Table(TABLE_NAME_USERS).Select("id", name", "phone").Limit(3).Query();

// select * from users limit 3
if rowsAffected, err := e.Model(&users).Table(TABLE_NAME_USERS).Limit(3).Query(); err != nil {
    log.Errorf("query into data model [%+v] error [%v]", users, err.Error())
} else {
    log.Debugf("query into model [%+v] ok, rows affected [%v]", users, rowsAffected)
}

orm: update from data model

user := UserDO{
    Id:    1, 
    Name:  "john",
    Phone: "8618699999999",
    Sex:   1,
    Email: "john@gmail.com",
}
//SQL: update users set name='john', phone='8618699999999', sex='1', email='john@gmail.com' where id='1'
if rowsAffected, err := e.Model(&user).Table(TABLE_NAME_USERS).Select("name", "phone", "email", "sex").Cache("phone").Update(); err != nil {
    log.Errorf("update data model [%+v] error [%v]", user, err.Error())
} else {
    log.Debugf("update data model [%+v] ok, rows affected [%v]", user, rowsAffected)
}

raw: query results into data model

user := UserDO{}

//SQL: select * from users where id=1
if rowsAffected, err := e.Model(&user).QueryRaw("select * from users where id=?", 1); err != nil {
    log.Errorf("query into data model [%+v] error [%v]", user, err.Error())
} else {
    log.Debugf("query into model [%+v] ok, rows affected [%v]", user, rowsAffected)
}

raw: query results into data model slice

var users []UserDO

//SQL: select * from users where id < 5
if rowsAffected, err := e.Model(&users).QueryRaw("select * from %v where id < %v", TABLE_NAME_USERS, 5); err != nil {
    log.Errorf("query into data model [%+v] error [%v]", users, err.Error())
} else {
    log.Debugf("query into model [%+v] ok, rows affected [%v]", users, rowsAffected)
}

raw: query results into data model map[string]string slice

var users []map[string]string

//SQL: select * from users where id < 5
if rowsAffected, err := e.Model(&users).QueryMap("select * from %v where id < %v", TABLE_NAME_USERS, 5); err != nil {
    log.Errorf("query into map [%+v] error [%v]", users, err.Error())
} else {
    log.Debugf("query into map [%+v] ok, rows affected [%v]", users, rowsAffected)
}

raw: exec without data model

//e.ExecRaw("UPDATE %v SET name='duck' WHERE id='%v'", TABLE_NAME_USERS, 2) //it will work well as question placeholder
rowsAffected, lasteInsertId, err := e.ExecRaw("UPDATE users SET name=? WHERE id=?", "duck", 1)
if err != nil {
    log.Errorf("exec raw sql error [%v]", err.Error())
} else {
    log.Debugf("exec raw sql ok, rows affected [%v] last insert id [%v]", rowsAffected, lasteInsertId)
}

save data to cache by id or index

just for orm [insert/upsert/update] see the example of orm update

change primary key name

e.SetPkName("uuid")

use cache when orm query/update/insert/upsert


e := sqlca.NewEngine()
e.Debug(true) //debug mode on

// open database driver (requred)
e.Open("mysql://root:123456@127.0.0.1:3306/test?charset=utf8mb4")

// open redis driver for cache (requred)
e.Open("redis://127.0.0.1:6379/cluster?db=0", 3600) //redis standalone mode

user := UserDO{
    Id:    0, 
    Name:  "john",
    Phone: "8618699999999",
    Sex:   1,
    Email: "john@gmail.com",
}
e.Model(&user).Table(TABLE_NAME_USERS).Cache("phone").Insert()

tx (TxBegin...TxGet...TxExec...TxCommit)


func SqlcaTxGetAndExec(e *sqlca.Engine) (err error) {

	var tx *sqlca.Engine
	//transaction: select user id form users where phone is '8618600000000' and update users disable to 1 by user id
	if tx, err = e.TxBegin(); err != nil {
		log.Errorf("TxBegin error [%v]", err.Error())
		return
	}

	var UserId int32

	//query results into base variants
	_, err = tx.TxGet(&UserId, "SELECT id FROM users WHERE phone='%v'", "8618600000000")
	if err != nil {
		log.Errorf("TxGet error %v", err.Error())
		_ = tx.TxRollback()
		return
	}
	var lastInsertId, rowsAffected int64
	if UserId == 0 {
		log.Warnf("select id users by phone number but user not exist")
		_ = tx.TxRollback()
		return
	}
	log.Debugf("base variant of user id [%+v]", UserId)
	lastInsertId, rowsAffected, err = tx.TxExec("UPDATE users SET disable=? WHERE id=?", 1, UserId)
	if err != nil {
		log.Errorf("TxExec error %v", err.Error())
		_ = tx.TxRollback()
		return
	}
	log.Debugf("user id [%v] disabled, last insert id [%v] rows affected [%v]", UserId, lastInsertId, rowsAffected)

	//query results into a struct object or slice
	var dos []UserDO
	_, err = tx.TxGet(&dos, "SELECT * FROM users WHERE disable=1")
	if err != nil {
		log.Errorf("TxGet error %v", err.Error())
		_ = tx.TxRollback()
		return
	}
	for _, do := range dos {
		log.Debugf("struct user data object [%+v]", do)
	}

	err = tx.TxCommit()
	return
}

index record to cache

user := UserDO{
    Id:    1,
    Name:  "john3",
    Phone: "8615011111114",
    Sex:   1,
    Email: "john3@gmail.com",
}

//SQL: update users set name='john3', phone='8615011111114', sex='1', email='john3@gmail.com' where id='1'
//index: name, phone
//redis key:  sqlx:cache:[table]:[column]:[column value]
if rowsAffected, err := e.Model(&user).
    Table(TABLE_NAME_USERS).
    Select("name", "phone", "email", "sex").
    Cache("name", "phone").
    Update(); err != nil {
    log.Errorf("update data model [%+v] error [%v]", user, err.Error())
} else {
    log.Debugf("update data model [%+v] ok, rows affected [%v]", user, rowsAffected)
}

attach exist sqlx db instance

// db is a exist sqlx.DB instance
e := sqlca.NewEngine().Attach(db)

set cache update before db update

e.SetCacheBefore(true)

delete from table


user := UserDO{
		Id: 1000,
}
//delete from data model
if rows, err := e.Model(&user).Table(TABLE_NAME_USERS).Delete(); err != nil {
    log.Errorf("delete from table error [%v]", err.Error())
} else {
    log.Debugf("delete from table ok, affected rows [%v]", rows)
}

//delete from where condition (without data model)
if rows, err := e.Table(TABLE_NAME_USERS).Where("id=1001").Delete(); err != nil {
    log.Errorf("delete from table error [%v]", err.Error())
} else {
    log.Debugf("delete from table ok, affected rows [%v]", rows)
}

//delete from primary key 'id' and value (without data model)
if rows, err := e.Table(TABLE_NAME_USERS).Id(1002).Where("disable=1").Delete(); err != nil {
    log.Errorf("delete from table error [%v]", err.Error())
} else {
    log.Debugf("delete from table ok, affected rows [%v]", rows)
}

select from multiple tables

type UserClass struct {
    UserId   int32  `db:"user_id"`
    UserName string `db:"user_name"`
    Phone    string `db:"phone"`
    ClassNo  string `db:"class_no"`
}
var ucs []UserClass
//SQL: SELECT a.*, b.class_no FROM users a, classes b WHERE a.id=b.user_id AND a.id=3
_, err := e.Model(&ucs).
    Select("a.id as user_id", "a.name", "a.phone", "b.class_no").
    Table("users a", "classes b").
    Where("a.id=b.user_id").
    And("a.id=?", 3).
    Query()
if err != nil {
    log.Errorf("query error [%v]", err.Error())
} else {
    log.Debugf("user class info [%+v]", ucs)
}

custom tag

type CustomUser struct {
    Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // protobuf tag
    Name  string `json:"name"`   // json tag
    Phone string `db:"phone"`    // db tag
}

var users []CustomUser
//add custom tag
e.SetCustomTag("protobuf", "json")
if count, err := e.Model(&users).
    Table(TABLE_NAME_USERS).
    Where("id < ?", 5).
    Query(); err != nil {
    log.Errorf("custom tag query error [%v]", err.Error())
} else {
    log.Debugf("custom tag query results %+v rows [%v]", users, count)
}

sqlca properties tag: readonly

type UserDO struct {
    Id    int32  `db:"id"` // protobuf tag
    Name  string `db:"name"`   // json tag
    Phone string `db:"phone"`    // db tag 
    CreatedAt string `db:"created_at" sqlca:"readonly"` //sqlca tag: readonly
}

Documentation

Index

Constants

View Source 
const (
	CACHE_INDEX_DEEP  = 1           // index deep in cache
	CACHE_REPLICATE   = "replicate" //replicate host [ip:port,...]
	CACHE_DB_INDEX    = "db"
	CAHCE_SQLX_PREFIX = "sqlca:cache"
)
View Source 
const (
	ValueType_Data  valueType = 1 // data of table
	ValueType_Index valueType = 2 // index of data
)
View Source 
const (
	TAG_NAME_DB       = "db"
	TAG_NAME_JSON     = "json"
	TAG_NAME_PROTOBUF = "protobuf"
	TAG_NAME_SQLCA    = "sqlca"
)
View Source 
const (
	SQLCA_TAG_VALUE_AUTO_INCR = "autoincr" //auto increment
	SQLCA_TAG_VALUE_READ_ONLY = "readonly" //read only (eg. created_at)
)
View Source 
const (
	DRIVER_NAME_MYSQL    = "mysql"
	DRIVER_NAME_POSTGRES = "postgres"
	DRIVER_NAME_SQLITE   = "sqlite3"
	DRIVER_NAME_MSSQL    = "mssql"
	DRIVER_NAME_REDIS    = "redis"
)
View Source 
const (
	DATABASE_KEY_NAME_WHERE    = "WHERE"
	DATABASE_KEY_NAME_UPDATE   = "UPDATE"
	DATABASE_KEY_NAME_SET      = "SET"
	DATABASE_KEY_NAME_FROM     = "FROM"
	DATABASE_KEY_NAME_DELETE   = "DELETE"
	DATABASE_KEY_NAME_SELECT   = "SELECT"
	DATABASE_KEY_NAME_DISTINCT = "DISTINCT"
	DATABASE_KEY_NAME_IN       = "IN"
	DATABASE_KEY_NAME_NOT_IN   = "NOT IN"
	DATABASE_KEY_NAME_OR       = "OR"
	DATABASE_KEY_NAME_AND      = "AND"
	DATABASE_KEY_NAME_INSERT   = "INSERT INTO"
	DATABASE_KEY_NAME_VALUE    = "VALUE"
	DATABASE_KEY_NAME_VALUES   = "VALUES"
)
View Source 
const (
	ORDER_BY_ASC                 = "asc"
	ORDER_BY_DESC                = "desc"
	DEFAULT_CAHCE_EXPIRE_SECONDS = 24 * 60 * 60
	DEFAULT_PRIMARY_KEY_NAME     = "id"
)
View Source 
const (
	ModelType_Struct   = 1
	ModelType_Slice    = 2
	ModelType_Map      = 3
	ModelType_BaseType = 4
)
View Source 
const (
	PROTOBUF_VALUE_NAME = "name"
)
View Source 
const (
	URL_SCHEME_SEP = "://"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AdapterType 

type AdapterType int
const (
	AdapterSqlx_MySQL    AdapterType = 1  //sqlx: mysql
	AdapterSqlx_Postgres AdapterType = 2  //sqlx: postgresql
	AdapterSqlx_Sqlite   AdapterType = 3  //sqlx: sqlite
	AdapterSqlx_Mssql    AdapterType = 4  //sqlx: mssql server
	AdapterCache_Redis   AdapterType = 11 //cache: redis
)

func (AdapterType) DriverName 

func (a AdapterType) DriverName() string

func (AdapterType) GoString 

func (a AdapterType) GoString() string

func (AdapterType) String 

func (a AdapterType) String() string

type Engine 

type Engine struct {
	// contains filtered or unexported fields
}

func NewEngine 

func NewEngine(args ...interface{}) *Engine

func (*Engine) And added in v1.0.5 

func (e *Engine) And(strFmt string, args ...interface{}) *Engine

func (*Engine) Asc 

func (e *Engine) Asc() *Engine

order by [field1,field2...] asc

func (*Engine) Attach added in v1.0.4 

func (e *Engine) Attach(strDatabaseName string, db *sqlx.DB) *Engine

attach from a exist sqlx db instance

func (*Engine) Cache added in v1.0.2 

func (e *Engine) Cache(indexes ...string) *Engine

set cache indexes. if null, the primary key (eg. 'id') will be cached to redis

func (*Engine) DB added in v1.0.7 

func (e *Engine) DB() *sqlx.DB

get sqlx db instance

func (*Engine) Debug 

func (e *Engine) Debug(ok bool)

debug mode on or off if debug on, some method will panic if your condition illegal

func (*Engine) Delete added in v1.0.4 

func (e *Engine) Delete() (rowsAffected int64, err error)

orm delete record(s) from db and cache

func (*Engine) Desc 

func (e *Engine) Desc() *Engine

order by [field1,field2...] desc

func (*Engine) Distinct added in v1.0.6 

func (e *Engine) Distinct() *Engine

set distinct when select

func (*Engine) ExecRaw 

func (e *Engine) ExecRaw(strQuery string, args ...interface{}) (rowsAffected, lastInsertId int64, err error)

use raw sql to insert/update database, results can not be cached to redis/memcached/memory... return rows affected and error, if err is not nil must be something wrong

func (*Engine) GetPkName 

func (e *Engine) GetPkName() string

func (*Engine) GroupBy 

func (e *Engine) GroupBy(strColumns ...string) *Engine

group by [field1,field2...]

func (*Engine) Id 

func (e *Engine) Id(value interface{}) *Engine

set orm primary key's value

func (*Engine) In added in v1.0.4 

func (e *Engine) In(strColumn string, args ...interface{}) *Engine

`field_name` IN ('1','2',...)

func (*Engine) Insert 

func (e *Engine) Insert() (lastInsertId int64, err error)

orm insert return last insert id and error, if err is not nil must be something wrong NOTE: Model function is must be called before call this function

func (*Engine) Limit 

func (e *Engine) Limit(args ...int) *Engine

query limit Limit(10) - query records limit 10 (mysql/postgres)

func (*Engine) Model 

func (e *Engine) Model(args ...interface{}) *Engine

orm model use to get result set, support single struct object or slice [pointer type] notice: will clone a new engine object for orm operations(query/update/insert/upsert)

func (*Engine) Not added in v1.0.5 

func (e *Engine) Not(strColumn string, args ...interface{}) *Engine

`field_name` NOT IN ('1','2',...)

func (*Engine) Offset 

func (e *Engine) Offset(offset int) *Engine

query offset (for mysql/postgres)

func (*Engine) OnConflict 

func (e *Engine) OnConflict(strColumns ...string) *Engine

set the conflict columns for upsert only for postgresql

func (*Engine) Open 

func (e *Engine) Open(strUrl string, expireSeconds ...int) *Engine

open a sqlx database or cache connection strUrl:

  1. data source name

    [mysql] Open("mysql://root:123456@127.0.0.1:3306/mydb?charset=utf8mb4") [postgres] Open("postgres://root:123456@127.0.0.1:5432/mydb?sslmode=disable") [sqlite] Open("sqlite:///var/lib/my.db") [mssql] Open("mssql://sa:123456@127.0.0.1:1433/mydb?instance=SQLExpress&windows=false")

  2. cache config [redis-alone] Open("redis://123456@127.0.0.1:6379/cluster?db=0") [redis-cluster] Open("redis://123456@127.0.0.1:6379/cluster?db=0&replicate=127.0.0.1:6380,127.0.0.1:6381")

expireSeconds cache data expire seconds, just for redis

func (*Engine) OrderBy 

func (e *Engine) OrderBy(strColumns ...string) *Engine

order by [field1,field2...]

func (*Engine) Query 

func (e *Engine) Query() (rowsAffected int64, err error)

orm query return rows affected and error, if err is not nil must be something wrong NOTE: Model function is must be called before call this function

func (*Engine) QueryMap 

func (e *Engine) QueryMap(strQuery string, args ...interface{}) (rowsAffected int64, err error)

use raw sql to query results into a map slice (model type is []map[string]string) return results and error NOTE: Model function is must be called before call this function

func (*Engine) QueryRaw 

func (e *Engine) QueryRaw(strQuery string, args ...interface{}) (rowsAffected int64, err error)

use raw sql to query results return rows affected and error, if err is not nil must be something wrong NOTE: Model function is must be called before call this function

func (*Engine) Select 

func (e *Engine) Select(strColumns ...string) *Engine

orm select/update columns

func (*Engine) SetCacheBefore added in v1.0.4 

func (e *Engine) SetCacheBefore(ok bool)

set cache update before database

func (*Engine) SetCustomTag added in v1.0.6 

func (e *Engine) SetCustomTag(tagNames ...string) *Engine

set your customer tag for db query/insert/update (eg. go structure generated by protobuf not contain 'db' tag) this function must calls before Model()

func (*Engine) SetLogFile added in v1.0.7 

func (e *Engine) SetLogFile(strPath string)

set log file

func (*Engine) SetPkName 

func (e *Engine) SetPkName(strName string) *Engine

set orm primary key's name, default named 'id'

func (*Engine) Table 

func (e *Engine) Table(strNames ...string) *Engine

set orm query table name(s) when your struct type name is not a table name

func (*Engine) TxBegin added in v1.0.3 

func (e *Engine) TxBegin() (*Engine, error)

func (*Engine) TxCommit added in v1.0.3 

func (e *Engine) TxCommit() error

func (*Engine) TxExec added in v1.0.3 

func (e *Engine) TxExec(strQuery string, args ...interface{}) (lastInsertId, rowsAffected int64, err error)

func (*Engine) TxGet added in v1.0.3 

func (e *Engine) TxGet(dest interface{}, strQuery string, args ...interface{}) (count int64, err error)

func (*Engine) TxRollback added in v1.0.3 

func (e *Engine) TxRollback() error

func (*Engine) Update 

func (e *Engine) Update() (rowsAffected int64, err error)

orm update from model strColumns... if set, columns will be updated, if none all columns in model will be updated except primary key return rows affected and error, if err is not nil must be something wrong NOTE: Model function is must be called before call this function

func (*Engine) Upsert 

func (e *Engine) Upsert() (lastInsertId int64, err error)

orm insert or update if key(s) conflict return last insert id and error, if err is not nil must be something wrong, if your primary key is not a int/int64 type, maybe id return 0 NOTE: Model function is must be called before call this function and call OnConflict function when you are on postgresql

func (*Engine) Where 

func (e *Engine) Where(strWhere string, args ...interface{}) *Engine

orm where condition

type Fetcher 

type Fetcher struct {
	// contains filtered or unexported fields
}

type ModelReflector 

type ModelReflector struct {
	// contains filtered or unexported fields
}

func (*ModelReflector) ToMap 

func (s *ModelReflector) ToMap(tagName string) map[string]interface{}

parse struct tag and value to map

type ModelType 

type ModelType int

func (ModelType) GoString 

func (m ModelType) GoString() string

func (ModelType) String 

func (m ModelType) String() string

type OperType 

type OperType int
const (
	OperType_Query    OperType = 1 // orm: query sql
	OperType_Update   OperType = 2 // orm: update sql
	OperType_Insert   OperType = 3 // orm: insert sql
	OperType_Upsert   OperType = 4 // orm: insert or update sql
	OperType_Tx       OperType = 5 // orm: tx sql
	OperType_QueryRaw OperType = 6 // raw: query sql into model
	OperType_ExecRaw  OperType = 7 // raw: insert/update sql
	OperType_QueryMap OperType = 8 // raw: query sql into map
	OperType_Delete   OperType = 9 // orm: delete sql
)

func (OperType) GoString 

func (o OperType) GoString() string

func (OperType) String 

func (o OperType) String() string

type UrlInfo 

type UrlInfo struct {
	Scheme     string
	Host       string // host name and port like '127.0.0.1:3306'
	User       string
	Password   string
	Path       string
	Fragment   string
	Opaque     string
	ForceQuery bool
	Queries    map[string]string
}

func ParseUrl 

func ParseUrl(strUrl string) (ui *UrlInfo)

URL have some special characters in password(支持URL中密码包含特殊字符)

Source Files

View all Source files

Directories

Path Synopsis
cmd
db2go
db2go/mssql
db2go/mysql
db2go/postgres
db2go/schema
dbloader
mssql
mysql
postgres

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.