commSql

README

功能说明

commSql对go原生的sql组件进行了封装，提供了commEntity.IEntity的schema的能力，从而能够形成自动ORM的能力

这里的ORM就是将对象实体的CRUD变成SQL的CRUD

Documentation

Index

• Variables
• func DeleteEntityById(entityType string, id int64) error
• func GetDBType() string
• func GetEntityType() []string
• func HasSchema(entityType string) bool
• func InsertEntity(entity commEntity.IEntity) error
• func InsertRecord(tableName string, entity commEntity.IEntity) error
• func Query(entityType string, sql string) ([]commEntity.IEntity, error)
• func QueryCount(sql string) (int, error)
• func QueryEntityById(entityType string, id int64) (commEntity.IEntity, error)
• func QueryEntityList(entityType string) ([]commEntity.IEntity, error)
• func Register(entityType string)
• func SQuery(entityType string, sql string, args []interface{}) ([]commEntity.IEntity, error)
• func SQueryCount(sql string, args []interface{}) (int, error)
• func UpdateEntityById(entity commEntity.IEntity) error
• func UpdateRecordById(tableName string, entity commEntity.IEntity) error
• type EntitySQL
  • func (e *EntitySQL) DeleteWhere(entityType string, where string) (string, error)
  • func (e *EntitySQL) DeleteWhereId(entityType string, id int64) (string, error)
  • func (e *EntitySQL) Insert(entity commEntity.IEntity) (string, []interface{}, error)
  • func (e *EntitySQL) InsertRecord(tblName string, entity commEntity.IEntity) (string, []interface{}, error)
  • func (e *EntitySQL) Select(entityType string) (string, error)
  • func (e *EntitySQL) SelectWhere(entityType string, where string) (string, error)
  • func (e *EntitySQL) SelectWhereId(entityType string, id int64) (string, error)
  • func (e *EntitySQL) UpdateRecordWhereId(tableName string, entity commEntity.IEntity) (string, []interface{}, error)
  • func (e *EntitySQL) UpdateWhereId(entity commEntity.IEntity) (string, []interface{}, error)
• type FieldValue
• type SQLOption
• type SqlClient
  • func (e *SqlClient) ConnectMySQL() error
  • func (e *SqlClient) ConnectSQLite(fileName string) error
  • func (e *SqlClient) Exec(sql string, values []interface{}) (int64, error)
  • func (e *SqlClient) Query(entityType string, sql string) ([]commEntity.IEntity, error)
  • func (e *SqlClient) QueryCount(sql string) (int, error)
  • func (e *SqlClient) QueryList(sql string, fields []FieldValue) ([]map[string]interface{}, error)
  • func (e *SqlClient) SQuery(entityType string, sql string, args []interface{}) ([]commEntity.IEntity, error)
  • func (e *SqlClient) SQueryCount(sql string, args []interface{}) (int, error)
  • func (e *SqlClient) SQueryList(sql string, fields []FieldValue, args []interface{}) ([]map[string]interface{}, error)

Variables

var (
	SQL          EntitySQL
	Client       *SqlClient
	Fox          foxSqlService
	SqlBuilder   sqlBuilder
	EntityEngine clientEntityEngine
)

Functions

func DeleteEntityById

func DeleteEntityById(entityType string, id int64) error

func GetDBType

func GetDBType() string

func GetEntityType

func GetEntityType() []string

func HasSchema

func HasSchema(entityType string) bool

func InsertEntity

func InsertEntity(entity commEntity.IEntity) error

func InsertRecord

func InsertRecord(tableName string, entity commEntity.IEntity) error

func Query

func Query(entityType string, sql string) ([]commEntity.IEntity, error)

func QueryCount

func QueryCount(sql string) (int, error)

func QueryEntityById

func QueryEntityById(entityType string, id int64) (commEntity.IEntity, error)

func QueryEntityList

func QueryEntityList(entityType string) ([]commEntity.IEntity, error)

func Register

func Register(entityType string)

func SQuery

func SQuery(entityType string, sql string, args []interface{}) ([]commEntity.IEntity, error)

func SQueryCount

func SQueryCount(sql string, args []interface{}) (int, error)

func UpdateEntityById

func UpdateEntityById(entity commEntity.IEntity) error

func UpdateRecordById

func UpdateRecordById(tableName string, entity commEntity.IEntity) error

Types

type EntitySQL

type EntitySQL struct {
}

func (*EntitySQL) DeleteWhere

func (e *EntitySQL) DeleteWhere(entityType string, where string) (string, error)

func (*EntitySQL) DeleteWhereId

func (e *EntitySQL) DeleteWhereId(entityType string, id int64) (string, error)

func (*EntitySQL) Insert

func (e *EntitySQL) Insert(entity commEntity.IEntity) (string, []interface{}, error)

func (*EntitySQL) InsertRecord

func (e *EntitySQL) InsertRecord(tblName string, entity commEntity.IEntity) (string, []interface{}, error)

func (*EntitySQL) Select

func (e *EntitySQL) Select(entityType string) (string, error)

func (*EntitySQL) SelectWhere

func (e *EntitySQL) SelectWhere(entityType string, where string) (string, error)

func (*EntitySQL) SelectWhereId

func (e *EntitySQL) SelectWhereId(entityType string, id int64) (string, error)

func (*EntitySQL) UpdateRecordWhereId

func (e *EntitySQL) UpdateRecordWhereId(tableName string, entity commEntity.IEntity) (string, []interface{}, error)

func (*EntitySQL) UpdateWhereId

func (e *EntitySQL) UpdateWhereId(entity commEntity.IEntity) (string, []interface{}, error)

type FieldValue

type FieldValue struct {
	Name  string
	Value interface{} //字段的数值
}

type SQLOption

type SQLOption struct {
	DriverName string
	DataSource string
}

type SqlClient

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

func (*SqlClient) ConnectMySQL

func (e *SqlClient) ConnectMySQL() error

func (*SqlClient) ConnectSQLite

func (e *SqlClient) ConnectSQLite(fileName string) error

func (*SqlClient) Exec

func (e *SqlClient) Exec(sql string, values []interface{}) (int64, error)

Exec 执行sql 参数：

sql 准备执行的sql语句
values sql语言中的参数表

说明：如果你构造的values参数为nil，那么你要确保自己的sql不含有文本参数的语句，不会发生注入式攻击

func (*SqlClient) Query

func (e *SqlClient) Query(entityType string, sql string) ([]commEntity.IEntity, error)

Query 查询数据 说明：直接执行SQL语句，不进行预处理

func (*SqlClient) QueryCount

func (e *SqlClient) QueryCount(sql string) (int, error)

func (*SqlClient) QueryList

func (e *SqlClient) QueryList(sql string, fields []FieldValue) ([]map[string]interface{}, error)

func (*SqlClient) SQuery

func (e *SqlClient) SQuery(entityType string, sql string, args []interface{}) ([]commEntity.IEntity, error)

SQuery 安全查询数据 说明：带预处理的方式执行SQL语句，防止注入攻击，或者特殊字符的冲突

func (*SqlClient) SQueryCount

func (e *SqlClient) SQueryCount(sql string, args []interface{}) (int, error)

func (*SqlClient) SQueryList

func (e *SqlClient) SQueryList(sql string, fields []FieldValue, args []interface{}) ([]map[string]interface{}, error)