db

Documentation

Index

• type BaseDbClient
  • func (b *BaseDbClient) Db() *sqlx.DB
  • func (b *BaseDbClient) Sq(builder squirrel.Sqlizer) types.DbClient
  • func (b *BaseDbClient) Sqrl(builder sqrl.Sqlizer) types.DbClient
  • func (b *BaseDbClient) ToSql() (string, []any, error)
  • func (b *BaseDbClient) XCount() (int64, error)
  • func (b *BaseDbClient) XGet(v any) error
  • func (b *BaseDbClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)
  • func (b *BaseDbClient) XSelect(v any, args ...*protobuf.ListParam) error
• type BaseDbProvider
  • func (b *BaseDbProvider) By(s string) types.DbClient
  • func (b *BaseDbProvider) Master() types.DbClient
  • func (b *BaseDbProvider) My() types.DbClient
  • func (b *BaseDbProvider) Slave(i int) types.DbClient
• type SqrlClient
  • func (b *SqrlClient) ToSql() (string, []any, error)
  • func (b *SqrlClient) XCount() (int64, error)
  • func (b *SqrlClient) XGet(v any) error
  • func (b *SqrlClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)
  • func (b *SqrlClient) XSelect(v any, args ...*protobuf.ListParam) error
• type SqurrelClient
  • func (b *SqurrelClient) ToSql() (string, []any, error)
  • func (b *SqurrelClient) XCount() (int64, error)
  • func (b *SqurrelClient) XGet(v any) error
  • func (b *SqurrelClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)
  • func (b *SqurrelClient) XSelect(v any, args ...*protobuf.ListParam) error

Types

type BaseDbClient

type BaseDbClient struct {
	*sqlx.DB
}

func (*BaseDbClient) Db

func (b *BaseDbClient) Db() *sqlx.DB

func (*BaseDbClient) Sq

func (b *BaseDbClient) Sq(builder squirrel.Sqlizer) types.DbClient

func (*BaseDbClient) Sqrl

func (b *BaseDbClient) Sqrl(builder sqrl.Sqlizer) types.DbClient

func (*BaseDbClient) ToSql

func (b *BaseDbClient) ToSql() (string, []any, error)

func (*BaseDbClient) XCount

func (b *BaseDbClient) XCount() (int64, error)

func (*BaseDbClient) XGet

func (b *BaseDbClient) XGet(v any) error

func (*BaseDbClient) XQuery

func (b *BaseDbClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)

func (*BaseDbClient) XSelect

func (b *BaseDbClient) XSelect(v any, args ...*protobuf.ListParam) error

type BaseDbProvider

type BaseDbProvider struct {
	Default types.DbClient            // 缺省的数据库连接
	Main    types.DbClient            // 主数据库连接,可读写
	Slaves  []types.DbClient          // 只读从数据库列表，只可读
	Items   map[string]types.DbClient // 额外数据库
}

func (*BaseDbProvider) By

func (b *BaseDbProvider) By(s string) types.DbClient

func (*BaseDbProvider) Master

func (b *BaseDbProvider) Master() types.DbClient

func (*BaseDbProvider) My

func (b *BaseDbProvider) My() types.DbClient

func (*BaseDbProvider) Slave

func (b *BaseDbProvider) Slave(i int) types.DbClient

type SqrlClient

type SqrlClient struct {
	*BaseDbClient
	// contains filtered or unexported fields
}

func (*SqrlClient) ToSql

func (b *SqrlClient) ToSql() (string, []any, error)

func (*SqrlClient) XCount

func (b *SqrlClient) XCount() (int64, error)

func (*SqrlClient) XGet

func (b *SqrlClient) XGet(v any) error

func (*SqrlClient) XQuery

func (b *SqrlClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)

func (*SqrlClient) XSelect

func (b *SqrlClient) XSelect(v any, args ...*protobuf.ListParam) error

type SqurrelClient

type SqurrelClient struct {
	*BaseDbClient
	// contains filtered or unexported fields
}

func (*SqurrelClient) ToSql

func (b *SqurrelClient) ToSql() (string, []any, error)

func (*SqurrelClient) XCount

func (b *SqurrelClient) XCount() (int64, error)

func (*SqurrelClient) XGet

func (b *SqurrelClient) XGet(v any) error

func (*SqurrelClient) XQuery

func (b *SqurrelClient) XQuery(args ...*protobuf.ListParam) (*sqlx.Rows, error)

func (*SqurrelClient) XSelect

func (b *SqurrelClient) XSelect(v any, args ...*protobuf.ListParam) error