dao

package
v0.0.0-...-b97b37b Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetLikeClausesByKeyWords 

func GetLikeClausesByKeyWords(keywords string, names ...string) []string

获取like子句, 只需要字符串类型数据 * * obj: 对象 * names: 需要生成like的对象

func JoinAndClauses 

func JoinAndClauses(clauses ...string) string

func JoinOrClauses 

func JoinOrClauses(clauses ...string) string

Types

type DBOperationDao 

type DBOperationDao struct {
	DB *sql.DB
}

func NewDBOperationDao 

func NewDBOperationDao(db *sql.DB) *DBOperationDao

func (*DBOperationDao) Close 

func (this *DBOperationDao) Close()

func (*DBOperationDao) GetThreadId 

func (this *DBOperationDao) GetThreadId() (int64, error)

获取链接ID

func (*DBOperationDao) Kill 

func (this *DBOperationDao) Kill(threadId int64) error

Kill 链接

func (*DBOperationDao) QueryRows 

func (this *DBOperationDao) QueryRows(query string) ([]map[string]interface{}, []string, error)
查询

Return 

[]map[string]interface{}: 返回数据行 rows
[]string: 返回字段名 columns
error: 错

func (*DBOperationDao) ShowDatabases 

func (this *DBOperationDao) ShowDatabases() ([]string, error)

func (*DBOperationDao) ShowTables 

func (this *DBOperationDao) ShowTables() ([]string, error)

type InstanceDao 

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

func NewInstanceDao 

func NewInstanceDao(db *gorm.DB) *InstanceDao

func (*InstanceDao) CountByKeyword 

func (this *InstanceDao) CountByKeyword(keyword string) (int, error)

func (*InstanceDao) Create 

func (this *InstanceDao) Create(instance *models.Instance) error

插入用户，先检查是否存在用户，如果没有则存入

func (*InstanceDao) FindByClusterId 

func (this *InstanceDao) FindByClusterId(clusterId int64) ([]*models.Instance, error)

通过集群id获取所有的实例

func (*InstanceDao) FindByKeyword 

func (this *InstanceDao) FindByKeyword(keyword string, offset, limit int) ([]*view_models.InstanceCluster, error)

func (*InstanceDao) FindInstanceClusterByClusterId 

func (this *InstanceDao) FindInstanceClusterByClusterId(clusterId int64) ([]*view_models.InstanceCluster, error)

通过集群id获取所有的实例

func (*InstanceDao) FindInstanceClusterByClusterName 

func (this *InstanceDao) FindInstanceClusterByClusterName(clusterName string) ([]*view_models.InstanceCluster, error)

通过集群Name获取所有的实例

func (*InstanceDao) FindInstanceClusterBySetName 

func (this *InstanceDao) FindInstanceClusterBySetName(setName string) ([]*view_models.InstanceCluster, error)

通过集群Name获取所有的实例

func (*InstanceDao) FindMasterByMetaClusterId 

func (this *InstanceDao) FindMasterByMetaClusterId(metaClusterId int64) ([]*models.Instance, error)

func (*InstanceDao) GetByInstance 

func (this *InstanceDao) GetByInstance(filterInstance *models.Instance) (*models.Instance, error)

获取一个实例信息, 通过 实例id 或 实例名称 或 机器ip, 或 vpcgw_rip

func (*InstanceDao) GetByInstanceId 

func (this *InstanceDao) GetByInstanceId(instanceId string) (*models.Instance, error)

func (*InstanceDao) GetByInstanceName 

func (this *InstanceDao) GetByInstanceName(instanceName string) (*models.Instance, error)

func (*InstanceDao) GetByMachineHostAndPort 

func (this *InstanceDao) GetByMachineHostAndPort(machineHost string, port int64) (*models.Instance, error)

func (*InstanceDao) GetByVpcgwRipAndPort 

func (this *InstanceDao) GetByVpcgwRipAndPort(vpcgwRip string, port int64) (*models.Instance, error)

func (*InstanceDao) GetMasterByMetaClusterId 

func (this *InstanceDao) GetMasterByMetaClusterId(metaClusterId int64) (*models.Instance, error)

func (*InstanceDao) UpdateById 

func (this *InstanceDao) UpdateById(instance *models.Instance) error

type MetaClusterDao 

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

func NewMetaClusterDao 

func NewMetaClusterDao(db *gorm.DB) *MetaClusterDao

func (*MetaClusterDao) All 

func (this *MetaClusterDao) All() ([]*models.MetaCluster, error)

func (*MetaClusterDao) AllName 

func (this *MetaClusterDao) AllName() ([]*models.MetaCluster, error)

func (*MetaClusterDao) CountByKeyword 

func (this *MetaClusterDao) CountByKeyword(keyword string) (int, error)

func (*MetaClusterDao) Create 

func (this *MetaClusterDao) Create(cluster *models.MetaCluster) error

插入用户，先检查是否存在用户，如果没有则存入

func (*MetaClusterDao) FindByIds 

func (this *MetaClusterDao) FindByIds(ids []int64) ([]*models.MetaCluster, error)

func (*MetaClusterDao) FindByKeyword 

func (this *MetaClusterDao) FindByKeyword(keyword string, offset, limit int) ([]*models.MetaCluster, error)

func (*MetaClusterDao) FindNameByName 

func (this *MetaClusterDao) FindNameByName(name string, limit int64) ([]*models.MetaCluster, error)

func (*MetaClusterDao) GetById 

func (this *MetaClusterDao) GetById(id int64) (*models.MetaCluster, error)

func (*MetaClusterDao) GetByIdEmptyError 

func (this *MetaClusterDao) GetByIdEmptyError(id int64) (*models.MetaCluster, error)

func (*MetaClusterDao) GetByName 

func (this *MetaClusterDao) GetByName(name string) (*models.MetaCluster, error)

func (*MetaClusterDao) UpdateById 

func (this *MetaClusterDao) UpdateById(cluster *models.MetaCluster) error

type MysqlDBPrivApplyDao 

type MysqlDBPrivApplyDao struct {
	DB *gorm.DB
}

func NewMysqlDBPrivApplyDao 

func NewMysqlDBPrivApplyDao(db *gorm.DB) *MysqlDBPrivApplyDao

func (*MysqlDBPrivApplyDao) BatchCreate 

func (this *MysqlDBPrivApplyDao) BatchCreate(applys []*models.MysqlDBPrivApply) error

批量创建权限申请信息

func (*MysqlDBPrivApplyDao) FindByUUID 

func (this *MysqlDBPrivApplyDao) FindByUUID(uuid string) ([]*models.MysqlDBPrivApply, error)

通过uuid 获取申请权限

type MysqlDBPrivApplyOrderDao 

type MysqlDBPrivApplyOrderDao struct {
	DB *gorm.DB
}

func NewMysqlDBPrivApplyOrderDao 

func NewMysqlDBPrivApplyOrderDao(db *gorm.DB) *MysqlDBPrivApplyOrderDao

func (*MysqlDBPrivApplyOrderDao) Count 

func (this *MysqlDBPrivApplyOrderDao) Count(order *models.MysqlDBPrivApplyOrder) (int64, error)

func (*MysqlDBPrivApplyOrderDao) Create 

func (this *MysqlDBPrivApplyOrderDao) Create(order *models.MysqlDBPrivApplyOrder) error

批量创建权限申请信息

func (*MysqlDBPrivApplyOrderDao) Find 

func (this *MysqlDBPrivApplyOrderDao) Find(order *models.MysqlDBPrivApplyOrder, offset, limit int) ([]*models.MysqlDBPrivApplyOrder, error)

func (*MysqlDBPrivApplyOrderDao) GetByUUID 

func (this *MysqlDBPrivApplyOrderDao) GetByUUID(uuid string) (*models.MysqlDBPrivApplyOrder, error)

func (*MysqlDBPrivApplyOrderDao) GetWhere 

func (this *MysqlDBPrivApplyOrderDao) GetWhere(order *models.MysqlDBPrivApplyOrder) string

func (*MysqlDBPrivApplyOrderDao) UpdateByUUID 

func (this *MysqlDBPrivApplyOrderDao) UpdateByUUID(order *models.MysqlDBPrivApplyOrder) error

func (*MysqlDBPrivApplyOrderDao) UpdateStatusApplying 

func (this *MysqlDBPrivApplyOrderDao) UpdateStatusApplying(id int64) error

func (*MysqlDBPrivApplyOrderDao) UpdateStatusFail 

func (this *MysqlDBPrivApplyOrderDao) UpdateStatusFail(id int64) error

func (*MysqlDBPrivApplyOrderDao) UpdateStatusSuccess 

func (this *MysqlDBPrivApplyOrderDao) UpdateStatusSuccess(id int64) error

type MysqlDBPrivDao 

type MysqlDBPrivDao struct {
	DB *gorm.DB
}

func NewMysqlDBPrivDao 

func NewMysqlDBPrivDao(db *gorm.DB) *MysqlDBPrivDao

func (*MysqlDBPrivDao) BatchReplace 

func (this *MysqlDBPrivDao) BatchReplace(privs []*models.MysqlDBPriv) error

批量创建权限信息

func (*MysqlDBPrivDao) CountByUsernameClusterDB 

func (this *MysqlDBPrivDao) CountByUsernameClusterDB(username string, meta_cluster_id int64, db_name string) (int64, error)

func (*MysqlDBPrivDao) FindPrivsTreeByUsername 

func (this *MysqlDBPrivDao) FindPrivsTreeByUsername(username string) ([]*models.MysqlDBPriv, error)

func (*MysqlDBPrivDao) GetById 

func (this *MysqlDBPrivDao) GetById(privId int64) (*models.MysqlDBPriv, error)

func (*MysqlDBPrivDao) GetByUsernameClusterDB 

func (this *MysqlDBPrivDao) GetByUsernameClusterDB(username string, meta_cluster_id int64, db_name string) (*models.MysqlDBPriv, error)

type MysqlDBPrivTrashDao 

type MysqlDBPrivTrashDao struct {
	DB *gorm.DB
}

func NewMysqlDBPrivTrashDao 

func NewMysqlDBPrivTrashDao(db *gorm.DB) *MysqlDBPrivTrashDao

func (*MysqlDBPrivTrashDao) BatchCreate 

func (this *MysqlDBPrivTrashDao) BatchCreate(trashs []*models.MysqlDBPrivTrash) error

批量创建权限申请信息

type UserDao 

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

func NewUserDao 

func NewUserDao(db *gorm.DB) *UserDao

func (*UserDao) All 

func (this *UserDao) All() ([]*models.User, error)

获取所有用户

func (*UserDao) CountByKeyword 

func (this *UserDao) CountByKeyword(keyword string) (int, error)

func (*UserDao) Create 

func (this *UserDao) Create(user *models.User) error

插入用户，先检查是否存在用户，如果没有则存入

func (*UserDao) FindByKeyword 

func (this *UserDao) FindByKeyword(keyword string, offset, limit int) ([]*models.User, error)

func (*UserDao) GetByUsername 

func (this *UserDao) GetByUsername(username string) (*models.User, error)

func (*UserDao) GetByUsernameAndPassword 

func (this *UserDao) GetByUsernameAndPassword(username, password string) (*models.User, error)

func (*UserDao) GetByUsernameEmptyError 

func (this *UserDao) GetByUsernameEmptyError(username string) (*models.User, error)

func (*UserDao) UpdateById 

func (this *UserDao) UpdateById(user *models.User) error

Source Files

View all Source files

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.