entgo

package module

v1.1.41 Latest Latest Go to latest Published: Nov 17, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateDriver(driverName, dsn string, enableTrace, enableMetrics bool) (*entSql.Driver, error)

CreateDriver 创建数据库驱动

func QueryAllChildrenIds[T EntClientInterface](ctx context.Context, entClient *EntClient[T], tableName string, parentID uint32) ([]uint32, error)

QueryAllChildrenIds 使用CTE递归查询所有子节点ID

func Rollback[T Rollbacker](tx T, err error) error

Rollback calls to tx.Rollback and wraps the given error

type EntClient[T EntClientInterface] struct {
	// contains filtered or unexported fields
}

func NewEntClient[T EntClientInterface](db T, drv *entSql.Driver) *EntClient[T]

func (c *EntClient[T]) Client() T

func (c *EntClient[T]) Close() error

Close 关闭数据库连接

func (c *EntClient[T]) DB() *sql.DB

func (c *EntClient[T]) Driver() *entSql.Driver

func (c *EntClient[T]) Exec(ctx context.Context, query string, args, v any) error

func (c *EntClient[T]) Query(ctx context.Context, query string, args, v any) error

Query 查询数据

func (c *EntClient[T]) SetConnectionOption(maxIdleConnections, maxOpenConnections int, connMaxLifetime time.Duration)

SetConnectionOption 设置连接配置

type EntClientInterface interface {
	Close() error
}

type Rollbacker interface {
	Rollback() error
}