Documentation
¶
Overview ¶
* @Author: lisheng * @Date: 2022-10-13 09:39:39 * @LastEditTime: 2023-01-06 14:13:33 * @LastEditors: lisheng * @Description: clickhouse 驱动 * @FilePath: /jf-go-kit/database/clickhouse/clickhouse.go
Index ¶
- func CreateDBEngnine(user string, pwd string, addr string, port int, db string) *gorm.DB
- func DeleteRecordByCond(engineName string, tableName string, cond string, objPtr interface{}) (affectedRows int64, err error)
- func FindRecordsByCond(engineName string, tableName string, cond string, page int, pageSize int, ...) error
- func InitCkManager() func() error
- func InsertRecord(engineName string, tableName string, objPtr interface{}) (affectedRows int64, err error)
- func RegisterTable(engineName string, tableObj interface{})
- func UpdateRecordByCond(engineName string, tableName string, cond string, ...) (affectedRows int64, err error)
- type CkManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateDBEngnine ¶
*
- @description: CreateDBEngnine
- @param {string} user
- @param {string} pwd
- @param {string} addr
- @param {int} port
- @param {string} db
- @return {*}
- @author: liqiyuWorks
func DeleteRecordByCond ¶
func DeleteRecordByCond(engineName string, tableName string, cond string, objPtr interface{}) (affectedRows int64, err error)
*
- @description: D - Where 删除 根据条件查询
- @param {string} tableName
- @param {string} cond
- @param {interface{}} objPtr
- @return {*}
- @author: liqiyuWorks
func FindRecordsByCond ¶
func FindRecordsByCond(engineName string, tableName string, cond string, page int, pageSize int, resultSlicePtr interface{}) error
*
- @description: R - Where 查询 根据条件查询
- @param {string} tableName
- @param {string} cond
- @param {string} condValue
- @param {int} page
- @param {int} pageSize
- @param {interface{}} resultSlicePtr
- @return {*}
- @author: liqiyuWorks
func InitCkManager ¶
func InitCkManager() func() error
*
- @description: 初始化CK
- @return {*}
- @author: liqiyuWorks
func InsertRecord ¶
func InsertRecord(engineName string, tableName string, objPtr interface{}) (affectedRows int64, err error)
*
- @description: C - 插入数据
- @param {string} tableName
- @param {string} cond
- @param {interface{}} objPtr
- @return {*}
- @author: liqiyuWorks
func RegisterTable ¶
func RegisterTable(engineName string, tableObj interface{})
*
- @description: CK AutoMigrate
- @param {string} engineName
- @param {interface{}} tableObj
- @return {*}
- @author: liqiyuWorks
func UpdateRecordByCond ¶
func UpdateRecordByCond(engineName string, tableName string, cond string, fieldMap map[string]interface{}) (affectedRows int64, err error)
*
- @description: U - Where 更新 根据条件查询
- @param {string} tableName
- @param {string} cond
- @param {map[string]interface{}} fieldMap
- @return {*}
- @author: liqiyuWorks
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.