db

package module

Go to main page

Versions in this module

v1

v1.1.1

Mar 23, 2026

Changes in this version

+ func ErrCursorPrimaryValueRequired(field string) error

type Config

+ EnableScheduledTaskFallback *bool

+ func (c *Config) ScheduledTaskFallbackEnabled() bool

type MongoQueryConstructor

+ func (qb *MongoQueryConstructor) Page(page int, pageSize int) QueryConstructor

+ func (qb *MongoQueryConstructor) Paginate(builder *PaginationBuilder) QueryConstructor

type Neo4jQueryConstructor

+ func (qb *Neo4jQueryConstructor) Page(page int, pageSize int) QueryConstructor

+ func (qb *Neo4jQueryConstructor) Paginate(builder *PaginationBuilder) QueryConstructor

+ type PagedQueryConstructorExecutionResult struct

+ Args []interface{}

+ CountCacheHit bool

+ HasNext bool

+ HasPrevious bool

+ Offset int

+ Page int

+ PageSize int

+ QueryCacheHit bool

+ Rows []map[string]interface{}

+ Statement string

+ Total int64

+ TotalPages int

+ type PaginationBuilder struct

+ CursorDirection string

+ CursorField string

+ CursorPrimaryValue interface{}

+ CursorValue interface{}

+ Mode PaginationMode

+ Page int

+ PageSize int

+ func NewCursorPaginationBuilder(field string, direction string, cursorValue interface{}, ...) *PaginationBuilder

+ func NewPaginationBuilder(page int, pageSize int) *PaginationBuilder

+ func (b *PaginationBuilder) CursorBy(field string, direction string, cursorValue interface{}, ...) *PaginationBuilder

+ func (b *PaginationBuilder) OffsetOnly() *PaginationBuilder

+ func (b *PaginationBuilder) WithMode(mode PaginationMode) *PaginationBuilder

+ type PaginationMode string

+ const PaginationModeAuto

+ const PaginationModeCursor

+ const PaginationModeOffset

type QueryConstructor

+ Page func(page int, pageSize int) QueryConstructor

+ Paginate func(builder *PaginationBuilder) QueryConstructor

type Repository

+ func (r *Repository) ExecuteQueryConstructorPaged(ctx context.Context, constructor QueryConstructor, page int, pageSize int) (*PagedQueryConstructorExecutionResult, error)

+ func (r *Repository) ExecuteQueryConstructorPagedWithCache(ctx context.Context, cacheKeyPrefix string, constructor QueryConstructor, ...) (*PagedQueryConstructorExecutionResult, error)

+ func (r *Repository) ExecuteQueryConstructorPaginated(ctx context.Context, constructor QueryConstructor, builder *PaginationBuilder) (*PagedQueryConstructorExecutionResult, error)

+ func (r *Repository) ExecuteQueryConstructorPaginatedWithCache(ctx context.Context, cacheKeyPrefix string, constructor QueryConstructor, ...) (*PagedQueryConstructorExecutionResult, error)

type SQLQueryConstructor

+ func (qb *SQLQueryConstructor) CursorPage(field string, direction string, cursorValue interface{}, ...) *SQLQueryConstructor

+ func (qb *SQLQueryConstructor) Page(page int, pageSize int) QueryConstructor

+ func (qb *SQLQueryConstructor) Paginate(builder *PaginationBuilder) QueryConstructor

v1.1.0

Mar 20, 2026

Changes in this version

type BaseSchema

+ func (s *BaseSchema) BelongsTo(target Schema) *SchemaRelationBuilder

+ func (s *BaseSchema) FindRelation(targetTable string) *SchemaRelation

+ func (s *BaseSchema) HasMany(target Schema) *SchemaRelationBuilder

+ func (s *BaseSchema) HasOne(target Schema) *SchemaRelationBuilder

+ func (s *BaseSchema) ManyToMany(target Schema) *SchemaRelationBuilder

+ func (s *BaseSchema) Relations() []SchemaRelation

+ type ConstrainedSchema interface

+ Constraints func() []TableConstraint

+ type CountBuilder struct

+ func NewCountBuilder(fieldName ...string) *CountBuilder

+ func (b *CountBuilder) As(alias string) *CountBuilder

+ func (b *CountBuilder) Distinct() *CountBuilder

+ type JoinBuilder struct

+ func NewCrossJoin(schema Schema) *JoinBuilder

+ func NewInnerJoin(schema Schema) *JoinBuilder

+ func NewJoinBuilder(joinType string, schema Schema) *JoinBuilder

+ func NewJoinWith(schema Schema) *JoinBuilder

+ func NewLeftJoin(schema Schema) *JoinBuilder

+ func NewOptionalJoin(schema Schema) *JoinBuilder

+ func NewRequiredJoin(schema Schema) *JoinBuilder

+ func NewRightJoin(schema Schema) *JoinBuilder

+ func (b *JoinBuilder) As(alias string) *JoinBuilder

+ func (b *JoinBuilder) Filter(conds ...Condition) *JoinBuilder

+ func (b *JoinBuilder) On(expr string) *JoinBuilder

+ func (b *JoinBuilder) Optional() *JoinBuilder

+ func (b *JoinBuilder) Required() *JoinBuilder

+ type JoinSemantic string

+ const JoinSemanticCross

+ const JoinSemanticInfer

+ const JoinSemanticOptional

+ const JoinSemanticRequired

type MongoCompiledFindPlan

+ Lookups []MongoLookupStage

type MongoConnectionConfig

+ HideThroughArtifacts *bool

+ RelationJoinStrategy string

+ type MongoLookupStage struct

+ As string

+ ForeignField string

+ From string

+ LocalField string

+ Semantic JoinSemantic

+ ThroughArtifact bool

type MongoQueryConstructor

+ func (qb *MongoQueryConstructor) Count(fieldName ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) CountWith(builder *CountBuilder) QueryConstructor

+ func (qb *MongoQueryConstructor) CustomMode() QueryConstructor

+ func (qb *MongoQueryConstructor) JoinWith(builder *JoinBuilder) QueryConstructor

+ func (qb *MongoQueryConstructor) SelectCount(ctx context.Context, repo *Repository) (int64, error)

+ func (qb *MongoQueryConstructor) Upsert(ctx context.Context, repo *Repository, cs *Changeset, ...) (sql.Result, error)

+ func (qb *MongoQueryConstructor) WhereWith(builder *WhereBuilder) QueryConstructor

type Neo4jQueryConstructor

+ func (qb *Neo4jQueryConstructor) Count(fieldName ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) CountWith(builder *CountBuilder) QueryConstructor

+ func (qb *Neo4jQueryConstructor) CustomMode() QueryConstructor

+ func (qb *Neo4jQueryConstructor) JoinWith(builder *JoinBuilder) QueryConstructor

+ func (qb *Neo4jQueryConstructor) SelectCount(ctx context.Context, repo *Repository) (int64, error)

+ func (qb *Neo4jQueryConstructor) Upsert(ctx context.Context, repo *Repository, cs *Changeset, ...) (sql.Result, error)

+ func (qb *Neo4jQueryConstructor) WhereWith(builder *WhereBuilder) QueryConstructor

type QueryConstructor

+ Count func(fieldName ...string) QueryConstructor

+ CountWith func(builder *CountBuilder) QueryConstructor

+ CustomMode func() QueryConstructor

+ JoinWith func(builder *JoinBuilder) QueryConstructor

+ SelectCount func(ctx context.Context, repo *Repository) (int64, error)

+ Upsert func(ctx context.Context, repo *Repository, cs *Changeset, ...) (sql.Result, error)

+ WhereWith func(builder *WhereBuilder) QueryConstructor

type QueryJoinIR

+ Filters []Condition

+ Relation *QueryJoinRelationIR

+ Schema Schema

+ Semantic JoinSemantic

+ type QueryJoinRelationIR struct

+ Direction string

+ Name string

+ ResolvedBy string

+ Reversible bool

+ Through *QueryRelationThroughIR

+ Type RelationType

+ type QueryRelationThroughIR struct

+ SourceKey string

+ Table string

+ TargetKey string

type QuerySourceIR

+ Schema Schema

+ type RelationThrough struct

+ Schema Schema

+ SourceKey string

+ Table string

+ TargetKey string

type RelationType

+ const RelationBelongsTo

+ const RelationHasMany

+ const RelationHasOne

+ const RelationManyToMany

+ type RelationalSchema interface

+ FindRelation func(targetTable string) *SchemaRelation

+ Relations func() []SchemaRelation

type SQLQueryConstructor

+ func (qb *SQLQueryConstructor) Count(fieldName ...string) QueryConstructor

+ func (qb *SQLQueryConstructor) CountWith(builder *CountBuilder) QueryConstructor

+ func (qb *SQLQueryConstructor) CustomMode() QueryConstructor

+ func (qb *SQLQueryConstructor) JoinWith(builder *JoinBuilder) QueryConstructor

+ func (qb *SQLQueryConstructor) SelectCount(ctx context.Context, repo *Repository) (int64, error)

+ func (qb *SQLQueryConstructor) Upsert(ctx context.Context, repo *Repository, cs *Changeset, ...) (sql.Result, error)

+ func (qb *SQLQueryConstructor) WhereWith(builder *WhereBuilder) QueryConstructor

type SQLServerConnectionConfig

+ ManyToManyStrategy string

+ RecursiveCTEDepth int

+ RecursiveCTEMaxRecursion int

type SQLServerDialect

+ func NewSQLServerDialectWithManyToManyStrategy(strategy string) *SQLServerDialect

+ func NewSQLServerDialectWithOptions(strategy string, recursiveCTEDepth int, maxRecursion int) *SQLServerDialect

+ func (d *SQLServerDialect) SQLManyToManyStrategy() string

+ func (d *SQLServerDialect) SQLRecursiveCTEDepth() int

+ func (d *SQLServerDialect) SQLRecursiveCTEMaxRecursion() int

+ type SchemaRelation struct

+ ForeignKey string

+ Name string

+ OriginKey string

+ Reversible bool

+ TargetSchema Schema

+ Through *RelationThrough

+ Type RelationType

+ func (r *SchemaRelation) Semantic() JoinSemantic

+ func (r *SchemaRelation) SemanticFromSource() JoinSemantic

+ type SchemaRelationBuilder struct

+ func (b *SchemaRelationBuilder) Named(name string) *SchemaRelationBuilder

+ func (b *SchemaRelationBuilder) Optional() *SchemaRelationBuilder

+ func (b *SchemaRelationBuilder) Over(foreignKey, originKey string) *SchemaRelationBuilder

+ func (b *SchemaRelationBuilder) Relation() *SchemaRelation

+ func (b *SchemaRelationBuilder) Required() *SchemaRelationBuilder

+ func (b *SchemaRelationBuilder) Reversible(enabled bool) *SchemaRelationBuilder

+ func (b *SchemaRelationBuilder) Through(through Schema, sourceKey, targetKey string) *SchemaRelationBuilder

type TableConstraint

+ Neo4jRelType string

+ type WhereBuilder struct

+ func NewWhereBuilder(condition Condition) *WhereBuilder

+ func (b *WhereBuilder) And(condition Condition) *WhereBuilder

+ func (b *WhereBuilder) Build() Condition

+ func (b *WhereBuilder) Not() *WhereBuilder

+ func (b *WhereBuilder) Or(condition Condition) *WhereBuilder

v1.0.3

Mar 20, 2026

Changes in this version

+ type MigrationOperation struct

+ AppliedAt time.Time

+ Description string

+ Kind MigrationOperationKind

+ Version string

+ type MigrationOperationKind string

+ const MigrationOpRecordApplied

+ const MigrationOpRemoveApplied

v1.0.2

Mar 19, 2026

v1.0.1

Mar 19, 2026

v1.0.0

Mar 18, 2026

Changes in this version

+ const DefaultCompiledQueryCacheDefaultTTLSeconds

+ const DefaultCompiledQueryCacheEnableMetrics

+ const DefaultCompiledQueryCacheMaxEntries

+ const StartupCapabilityFullTextRuntime

+ const StartupCapabilityJSONRuntime

+ var GlobalCrossTableViewRegistry = NewCrossTableViewRegistry()

+ var Presets = PresetRegistry

+ func ConfigureValidationLocales(defaultLocale string, enabledLocales []string) error

+ func DaysLater(days int) time.Time

+ func DaysLaterUTC(days int) time.Time

+ func DefaultSQLiteJSONFallbackFunctions() map[string]interface

+ func EndOfCurrentMonth() time.Time

+ func EndOfCurrentQuarter() time.Time

+ func ExampleSQLServerDynamicTable()

+ func GetEnabledValidationLocales() []string

+ func GetValidationLocale() string

+ func JSONExtractGo(jsonText string, path string) interface

+ func MonthsLater(months int) time.Time

+ func MonthsLaterUTC(months int) time.Time

+ func NextBillingDate(day int) time.Time

+ func OneYearLater() time.Time

+ func OneYearLaterUTC() time.Time

+ func RegisterSQLiteJSONFallbackDriver(driverName string, extraFunctions map[string]interface{}) error

+ func RegisterSchemasIntoGlobal(schemas ...Schema)

+ func RegisterValidationProfile(profile ValidationProfile) error

+ func SLADeadline(hours int, workdaysOnly bool) time.Time

+ func SetLegacyQueryBuilderWarningEnabled(enabled bool)

+ func SetLowLevelTransactionWarningEnabled(enabled bool)

+ func SetValidationLocale(locale string) error

+ func StartOfCurrentMonth() time.Time

+ func StartOfCurrentQuarter() time.Time

+ func ValidationLocaleExists(locale string) bool

+ func ValidationLocaleFromContext(ctx context.Context) string

+ func WithValidationLocale(ctx context.Context, locale string) context.Context

+ func YearsLater(years int) time.Time

+ func YearsLaterUTC(years int) time.Time

+ type AutoShardingManager struct

+ func NewAutoShardingManager(hook DynamicTableHook, configName string, template *AutoShardingTemplate) (*AutoShardingManager, error)

+ func (m *AutoShardingManager) EnsureShardTable(ctx context.Context, values map[string]interface{}) (string, error)

+ func (m *AutoShardingManager) ResolveShardID(values map[string]interface{}) (string, error)

+ type AutoShardingTemplate struct

+ AllowedRegions map[string]struct{}

+ DateGranularity DateShardingGranularity

+ KeyField string

+ Kind ShardingTemplateKind

+ ShardCount int

+ func NewDataScaleShardingTemplate(keyField string, shardCount int) *AutoShardingTemplate

+ func NewDateShardingTemplate(keyField string, granularity DateShardingGranularity) *AutoShardingTemplate

+ func NewRegionShardingTemplate(keyField string, allowedRegions ...string) *AutoShardingTemplate

+ func (t *AutoShardingTemplate) ResolveShardID(values map[string]interface{}) (string, error)

+ type BaseSQLCompiler struct

+ func NewBaseSQLCompiler(dialect SQLDialect) *BaseSQLCompiler

+ func (c *BaseSQLCompiler) Compile(ctx context.Context, ir *QueryIR) (string, []interface{}, error)

+ func (c *BaseSQLCompiler) SetDialect(dialect SQLDialect)

type BaseSchema

+ func (s *BaseSchema) AddForeignKey(name string, localFields []string, refTable string, refFields []string, ...) *BaseSchema

+ func (s *BaseSchema) AddPrimaryKey(fields ...string) *BaseSchema

+ func (s *BaseSchema) AddSoftDelete() *BaseSchema

+ func (s *BaseSchema) AddTimestamps() *BaseSchema

+ func (s *BaseSchema) AddUniqueConstraint(name string, fields ...string) *BaseSchema

+ func (s *BaseSchema) Constraints() []TableConstraint

type Changeset

+ func (cs *Changeset) ValidateChangeWithContext(ctx context.Context, fieldName string, validator Validator) *Changeset

+ func (cs *Changeset) ValidateChangeWithLocale(fieldName string, validator Validator, locale string) *Changeset

+ func (cs *Changeset) ValidateWithContext(ctx context.Context) *Changeset

+ func (cs *Changeset) ValidateWithLocale(locale string) *Changeset

+ type ChangesetExecutor struct

+ func (e *ChangesetExecutor) Delete(whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (e *ChangesetExecutor) DeleteByID(id interface{}) (sql.Result, error)

+ func (e *ChangesetExecutor) Insert(cs *Changeset) (sql.Result, error)

+ func (e *ChangesetExecutor) SoftDelete(whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (e *ChangesetExecutor) SoftDeleteByID(id interface{}) (sql.Result, error)

+ func (e *ChangesetExecutor) Update(cs *Changeset, whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (e *ChangesetExecutor) UpdateByID(id interface{}, cs *Changeset) (sql.Result, error)

+ type CompiledQuery struct

+ Args []interface{}

+ Query string

+ type CompiledQueryCache struct

+ func NewCompiledQueryCache() *CompiledQueryCache

+ func NewCompiledQueryCacheWithOptions(maxEntries int, defaultTTL time.Duration, enableMetrics bool) *CompiledQueryCache

+ func NewCompiledQueryCacheWithSize(maxEntries int) *CompiledQueryCache

+ type CompiledQueryCacheStats struct

+ CostAdded uint64

+ CostEvicted uint64

+ Enabled bool

+ GetsDropped uint64

+ GetsKept uint64

+ HitRatio float64

+ Hits uint64

+ KeysAdded uint64

+ KeysEvicted uint64

+ KeysUpdated uint64

+ MaxCost int64

+ Misses uint64

+ RemainingCost int64

+ SetsDropped uint64

+ SetsRejected uint64

+ type CompiledQueryTemplate struct

+ ArgCount int

+ Query string

+ type CompositeTypeBuilder struct

+ func (b *CompositeTypeBuilder) AddField(ctx context.Context, name, pgType string) error

+ func (b *CompositeTypeBuilder) Build() (string, error)

+ func (b *CompositeTypeBuilder) Create(ctx context.Context) error

+ func (b *CompositeTypeBuilder) Drop(ctx context.Context, ifExists bool) error

+ func (b *CompositeTypeBuilder) Exists(ctx context.Context) (bool, error)

+ func (b *CompositeTypeBuilder) Field(name, pgType string) *CompositeTypeBuilder

+ func (b *CompositeTypeBuilder) IfNotExists() *CompositeTypeBuilder

+ func (b *CompositeTypeBuilder) Schema(schema string) *CompositeTypeBuilder

type Condition

+ func ActiveUsersInBusinessHours() Condition

+ func ActiveUsersInBusinessHoursBy(statusField string, activeValue interface{}, timeField string, ...) Condition

+ func DateFrom(field string, start time.Time) Condition

+ func DateInBusinessHours(field string, startHour, endHour int) Condition

+ func DateInCurrentMonth(field string) Condition

+ func DateInCurrentQuarter(field string) Condition

+ func DateInLastBusinessDays(field string, days int, holidays ...time.Time) Condition

+ func DateOn(field string, year, month, day int) Condition

+ func DateRange(field string, start, end time.Time) Condition

+ func DateTo(field string, end time.Time) Condition

+ func DueSoonTasksInBusinessDays(days int, holidays ...time.Time) Condition

+ func EqFields(values map[string]interface{}) Condition

+ func FullText(field string, query string) Condition

+ func OrdersInCurrentQuarter() Condition

+ func OrdersInCurrentQuarterBy(timeField string) Condition

type Config

+ MongoDB *MongoConnectionConfig

+ MySQL *MySQLConnectionConfig

+ Neo4j *Neo4jConnectionConfig

+ Postgres *PostgresConnectionConfig

+ QueryCache *QueryCacheConfig

+ SQLServer *SQLServerConnectionConfig

+ SQLite *SQLiteConnectionConfig

+ StartupCapabilities *StartupCapabilityConfig

+ Validation *ValidationConfig

+ func LoadConfigFromEnv(adapter string) (*Config, error)

+ func LoadConfigFromEnvWithDefaults(adapter string, defaults *Config) (*Config, error)

+ func (c *Config) ResolvedMongoConfig() *MongoConnectionConfig

+ func (c *Config) ResolvedMySQLConfig() *MySQLConnectionConfig

+ func (c *Config) ResolvedNeo4jConfig() *Neo4jConnectionConfig

+ func (c *Config) ResolvedPostgresConfig() *PostgresConnectionConfig

+ func (c *Config) ResolvedSQLServerConfig() *SQLServerConnectionConfig

+ func (c *Config) ResolvedSQLiteConfig() *SQLiteConnectionConfig

+ type ConstraintKind string

+ const ConstraintForeignKey

+ const ConstraintPrimaryKey

+ const ConstraintUnique

+ type CrossTableStrategy string

+ const CrossTableStrategyAuto

+ const CrossTableStrategyForceDirectJoin

+ const CrossTableStrategyPreferTempTable

+ type CrossTableViewEntry struct

+ JoinFields []string

+ LocalAlias string

+ LocalTable string

+ Materialized bool

+ RefAlias string

+ RefFields []string

+ RefTable string

+ ViewName string

+ type CrossTableViewRegistry struct

+ func NewCrossTableViewRegistry() *CrossTableViewRegistry

+ func (r *CrossTableViewRegistry) Lookup(localTable, refTable string) (*CrossTableViewEntry, bool)

+ func (r *CrossTableViewRegistry) LookupAny(tableA, tableB string) (*CrossTableViewEntry, bool)

+ func (r *CrossTableViewRegistry) Register(entry *CrossTableViewEntry)

+ func (r *CrossTableViewRegistry) RegisterFromSchema(schema Schema)

+ type CustomFeatureProvider interface

+ ExecuteCustomFeature func(ctx context.Context, feature string, input map[string]interface{}) (interface{}, error)

+ HasCustomFeatureImplementation func(feature string) bool

+ type CypherCompiler struct

+ func NewCypherCompiler() *CypherCompiler

+ func (c *CypherCompiler) Compile(ctx context.Context, ir *QueryIR) (string, []interface{}, error)

+ type CypherConditionTranslator struct

+ func (t *CypherConditionTranslator) TranslateComposite(operator string, conditions []Condition) (string, []interface{}, error)

+ func (t *CypherConditionTranslator) TranslateCondition(condition Condition) (string, []interface{}, error)

+ type CypherWriteSummary struct

+ LabelsAdded int

+ LabelsRemoved int

+ NodesCreated int

+ NodesDeleted int

+ PropertiesSet int

+ RelationshipsCreated int

+ RelationshipsDeleted int

type DatabaseFeatures

+ FallbackStrategies map[string]FeatureFallback

+ FeatureSupport map[string]FeatureSupport

+ SupportsCompositeForeignKeys bool

+ SupportsForeignKeys bool

+ func NewNeo4jDatabaseFeatures() *DatabaseFeatures

+ func (f *DatabaseFeatures) GetFallbackStrategy(feature string) FeatureFallback

+ func (f *DatabaseFeatures) GetFeatureSupport(feature string) FeatureSupport

+ func (f *DatabaseFeatures) SupportsFeatureWithVersion(feature, version string) bool

+ type DateBuilder struct

+ func DateByYMD(year, month, day int) *DateBuilder

+ func TodayBuilder() *DateBuilder

+ func TodayUTCBuilder() *DateBuilder

+ func (b *DateBuilder) AddDays(days int) *DateBuilder

+ func (b *DateBuilder) AddMonths(months int) *DateBuilder

+ func (b *DateBuilder) AddYears(years int) *DateBuilder

+ func (b *DateBuilder) At(hour, minute, second int) *DateBuilder

+ func (b *DateBuilder) Build() time.Time

+ func (b *DateBuilder) EndOfMonth() *DateBuilder

+ func (b *DateBuilder) EndOfQuarter() *DateBuilder

+ func (b *DateBuilder) In(loc *time.Location) *DateBuilder

+ func (b *DateBuilder) StartOfMonth() *DateBuilder

+ func (b *DateBuilder) StartOfQuarter() *DateBuilder

+ type DatePresetRegistry struct

+ func (DatePresetRegistry) ActiveUsersInBusinessHours() Condition

+ func (DatePresetRegistry) ActiveUsersInBusinessHoursBy(statusField string, activeValue interface{}, timeField string, ...) Condition

+ func (DatePresetRegistry) DueSoonTasksInBusinessDays(days int, holidays ...time.Time) Condition

+ func (DatePresetRegistry) OrdersInCurrentQuarter() Condition

+ func (DatePresetRegistry) OrdersInCurrentQuarterBy(timeField string) Condition

+ type DateShardingGranularity string

+ const DateShardingByDay

+ const DateShardingByMonth

+ const DateShardingByYear

type DefaultSQLQueryConstructorProvider

+ func (p *DefaultSQLQueryConstructorProvider) SetCompiler(compiler QueryCompiler) *DefaultSQLQueryConstructorProvider

+ type DialectAwareQueryCompiler interface

+ SetDialect func(dialect SQLDialect)

+ type DomainTypeBuilder struct

+ func (b *DomainTypeBuilder) BaseType(pgType string) *DomainTypeBuilder

+ func (b *DomainTypeBuilder) Build() (string, error)

+ func (b *DomainTypeBuilder) Check(expression string) *DomainTypeBuilder

+ func (b *DomainTypeBuilder) CheckNamed(constraintName, expression string) *DomainTypeBuilder

+ func (b *DomainTypeBuilder) Create(ctx context.Context) error

+ func (b *DomainTypeBuilder) Default(expr string) *DomainTypeBuilder

+ func (b *DomainTypeBuilder) Drop(ctx context.Context, ifExists bool) error

+ func (b *DomainTypeBuilder) Exists(ctx context.Context) (bool, error)

+ func (b *DomainTypeBuilder) IfNotExists() *DomainTypeBuilder

+ func (b *DomainTypeBuilder) NotNull() *DomainTypeBuilder

+ func (b *DomainTypeBuilder) Schema(schema string) *DomainTypeBuilder

type EmailValidator

+ Locale string

+ func NewEmailValidatorForLocale(locale string) *EmailValidator

+ func (v *EmailValidator) ValidateWithLocale(value interface{}, locale string) error

+ type EnumTypeBuilder struct

+ func (b *EnumTypeBuilder) Build() (string, error)

+ func (b *EnumTypeBuilder) Create(ctx context.Context) error

+ func (b *EnumTypeBuilder) Drop(ctx context.Context, ifExists bool) error

+ func (b *EnumTypeBuilder) Exists(ctx context.Context) (bool, error)

+ func (b *EnumTypeBuilder) IfNotExists() *EnumTypeBuilder

+ func (b *EnumTypeBuilder) Schema(schema string) *EnumTypeBuilder

+ func (b *EnumTypeBuilder) Values(vals ...string) *EnumTypeBuilder

+ type FKOption func(*TableConstraint)

+ func WithJoinType(joinType string) FKOption

+ func WithViewHint(viewName string, materialized bool, columns ...string) FKOption

+ type FeatureExecutionDecision struct

+ Fallback FeatureFallback

+ Mode FeatureExecutionMode

+ Reason string

+ type FeatureExecutionMode string

+ const FeatureExecutionCustom

+ const FeatureExecutionFallback

+ const FeatureExecutionNative

+ const FeatureExecutionUnsupported

type FieldType

+ const TypeLocation

+ type FullTextRuntimeCapability struct

+ NativeSupported bool

+ Notes string

+ PluginAvailable bool

+ PluginChecked bool

+ PluginName string

+ TokenizationMode string

+ TokenizationSupported bool

+ type FullTextRuntimeInspector interface

+ InspectFullTextRuntime func(ctx context.Context) (*FullTextRuntimeCapability, error)

+ type FuzzySearchPlan struct

+ Condition Condition

+ Mode string

+ Reason string

+ Tokens []string

+ type IDCardValidator struct

+ Locale string

+ func NewIDCardValidatorForLocale(locale string) *IDCardValidator

+ func (v *IDCardValidator) Validate(value interface{}) error

+ func (v *IDCardValidator) ValidateWithLocale(value interface{}, locale string) error

+ type JSONRuntimeCapability struct

+ NativeJSONTypeSupported bool

+ NativeSupported bool

+ Notes string

+ PluginAvailable bool

+ PluginChecked bool

+ PluginName string

+ Version string

+ type JSONRuntimeInspector interface

+ InspectJSONRuntime func(ctx context.Context) (*JSONRuntimeCapability, error)

+ type LocalCacheStats struct

+ Fresh int

+ Stale int

+ Total int

+ type LocaleAwareValidator interface

+ ValidateWithLocale func(value interface{}, locale string) error

type MongoAdapter

+ func (a *MongoAdapter) ExecuteCompiledFindPlan(ctx context.Context, query string) ([]map[string]interface{}, error)

+ func (a *MongoAdapter) ExecuteCompiledWritePlan(ctx context.Context, query string) (*QueryConstructorExecSummary, error)

+ func (a *MongoAdapter) ExecuteCustomFeature(ctx context.Context, feature string, input map[string]interface{}) (interface{}, error)

+ func (a *MongoAdapter) HasCustomFeatureImplementation(feature string) bool

+ func (a *MongoAdapter) InspectFullTextRuntime(ctx context.Context) (*FullTextRuntimeCapability, error)

+ type MongoCompiledFindPlan struct

+ Collection string

+ Filter map[string]interface{}

+ Limit *int

+ Offset *int

+ Projection []string

+ Sort []MongoSortField

+ type MongoCompiledWritePlan struct

+ Collection string

+ Document map[string]interface{}

+ Documents []map[string]interface{}

+ Filter map[string]interface{}

+ Operation string

+ ReturnInsertedID bool

+ ReturnWriteDetail bool

+ Update map[string]interface{}

+ Upsert bool

+ type MongoConnectionConfig struct

+ Database string

+ URI string

+ type MongoLocalCache struct

+ func GetMongoLocalCache(adapter Adapter) (*MongoLocalCache, bool)

+ func (c *MongoLocalCache) ForcePreload(ctx context.Context, name, collection string, filter, projection bson.D, ...) error

+ func (c *MongoLocalCache) Get(name string) ([]bson.M, bool)

+ func (c *MongoLocalCache) Invalidate(name string)

+ func (c *MongoLocalCache) InvalidateAll()

+ func (c *MongoLocalCache) JoinWith(localDocs []bson.M, localKey, cacheName, cacheKey, asField string, many bool) []bson.M

+ func (c *MongoLocalCache) Preload(ctx context.Context, name, collection string, filter, projection bson.D, ...) error

+ func (c *MongoLocalCache) Stats() LocalCacheStats

+ type MongoQueryConstructor struct

+ func NewMongoQueryConstructor(schema Schema) *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) Build(ctx context.Context) (string, []interface{}, error)

+ func (qb *MongoQueryConstructor) BuildFindPlan() (*MongoCompiledFindPlan, error)

+ func (qb *MongoQueryConstructor) CrossJoin(table string, alias ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) CrossTableStrategy(strategy CrossTableStrategy) QueryConstructor

+ func (qb *MongoQueryConstructor) DeleteMany() *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) FromAlias(alias string) QueryConstructor

+ func (qb *MongoQueryConstructor) GetNativeBuilder() interface{}

+ func (qb *MongoQueryConstructor) InsertMany(documents []map[string]interface{}) *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) InsertOne(document map[string]interface{}) *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) Join(table, onClause string, alias ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) LeftJoin(table, onClause string, alias ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) Limit(count int) QueryConstructor

+ func (qb *MongoQueryConstructor) Offset(count int) QueryConstructor

+ func (qb *MongoQueryConstructor) OrderBy(field string, direction string) QueryConstructor

+ func (qb *MongoQueryConstructor) ReturnInsertedID() *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) ReturnWriteDetail() *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) RightJoin(table, onClause string, alias ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) Select(fields ...string) QueryConstructor

+ func (qb *MongoQueryConstructor) UpdateMany(setFields map[string]interface{}, upsert bool) *MongoQueryConstructor

+ func (qb *MongoQueryConstructor) Where(condition Condition) QueryConstructor

+ func (qb *MongoQueryConstructor) WhereAll(conditions ...Condition) QueryConstructor

+ func (qb *MongoQueryConstructor) WhereAny(conditions ...Condition) QueryConstructor

+ type MongoQueryConstructorProvider struct

+ func NewMongoQueryConstructorProvider() *MongoQueryConstructorProvider

+ func (p *MongoQueryConstructorProvider) GetCapabilities() *QueryBuilderCapabilities

+ func (p *MongoQueryConstructorProvider) NewQueryConstructor(schema Schema) QueryConstructor

+ type MongoSortField struct

+ Direction int

+ Field string

+ type MongoTTLFeatures struct

+ func GetMongoTTLFeatures(adapter Adapter) (*MongoTTLFeatures, bool)

+ func (f *MongoTTLFeatures) DropTTLIndex(ctx context.Context, collection, indexName string) error

+ func (f *MongoTTLFeatures) EnsureTTLIndex(ctx context.Context, collection, field string, expireAfter time.Duration) error

+ func (f *MongoTTLFeatures) ExtendExpiry(ctx context.Context, collection string, filter bson.D, ttlField string, ...) error

+ func (f *MongoTTLFeatures) InsertWithExpiry(ctx context.Context, collection string, doc bson.M, ttlField string, ...) error

+ func (f *MongoTTLFeatures) ListTTLIndexes(ctx context.Context, collection string) ([]*TTLIndexInfo, error)

+ type MongoVirtualView struct

+ func GetMongoVirtualView(adapter Adapter) (*MongoVirtualView, bool)

+ func (v *MongoVirtualView) Define(name, collection string, pipeline bson.A, ttl time.Duration)

+ func (v *MongoVirtualView) DefinedViews() []string

+ func (v *MongoVirtualView) Execute(ctx context.Context, name string) ([]bson.M, error)

+ func (v *MongoVirtualView) InvalidateAll()

+ func (v *MongoVirtualView) InvalidateView(name string)

+ func (v *MongoVirtualView) IsCached(name string) bool

+ func (v *MongoVirtualView) IsDefined(name string) bool

+ func (v *MongoVirtualView) Refresh(ctx context.Context, name string) ([]bson.M, error)

+ type MySQLConnectionConfig struct

+ DSN string

+ Database string

+ Host string

+ Password string

+ Port int

+ Username string

+ type Neo4jAdapter struct

+ func NewNeo4jAdapter(config *Config) (*Neo4jAdapter, error)

+ func (a *Neo4jAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *Neo4jAdapter) Close() error

+ func (a *Neo4jAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *Neo4jAdapter) Exec(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

+ func (a *Neo4jAdapter) ExecCypher(ctx context.Context, cypher string, params map[string]interface{}) (*CypherWriteSummary, error)

+ func (a *Neo4jAdapter) ExecuteCustomFeature(ctx context.Context, feature string, input map[string]interface{}) (interface{}, error)

+ func (a *Neo4jAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *Neo4jAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *Neo4jAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *Neo4jAdapter) GetRawConn() interface{}

+ func (a *Neo4jAdapter) HasCustomFeatureImplementation(feature string) bool

+ func (a *Neo4jAdapter) InspectFullTextRuntime(ctx context.Context) (*FullTextRuntimeCapability, error)

+ func (a *Neo4jAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *Neo4jAdapter) Ping(ctx context.Context) error

+ func (a *Neo4jAdapter) Query(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

+ func (a *Neo4jAdapter) QueryCypher(ctx context.Context, cypher string, params map[string]interface{}) ([]map[string]interface{}, error)

+ func (a *Neo4jAdapter) QueryRow(ctx context.Context, sql string, args ...interface{}) *sql.Row

+ func (a *Neo4jAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *Neo4jAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type Neo4jConnectionConfig struct

+ Database string

+ Password string

+ URI string

+ Username string

+ type Neo4jFactory struct

+ func (f *Neo4jFactory) Create(config *Config) (Adapter, error)

+ func (f *Neo4jFactory) Name() string

+ type Neo4jQueryConstructor struct

+ func NewNeo4jQueryConstructor(schema Schema) *Neo4jQueryConstructor

+ func NewNeo4jQueryConstructorWithCompiler(schema Schema, compiler QueryCompiler) *Neo4jQueryConstructor

+ func (qb *Neo4jQueryConstructor) Build(ctx context.Context) (string, []interface{}, error)

+ func (qb *Neo4jQueryConstructor) BuildIR(ctx context.Context) (*QueryIR, error)

+ func (qb *Neo4jQueryConstructor) CrossJoin(table string, alias ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) CrossTableStrategy(strategy CrossTableStrategy) QueryConstructor

+ func (qb *Neo4jQueryConstructor) FromAlias(alias string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) GetNativeBuilder() interface{}

+ func (qb *Neo4jQueryConstructor) Join(table, onClause string, alias ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) LeftJoin(table, onClause string, alias ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) Limit(count int) QueryConstructor

+ func (qb *Neo4jQueryConstructor) Offset(count int) QueryConstructor

+ func (qb *Neo4jQueryConstructor) OrderBy(field string, direction string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) RightJoin(table, onClause string, alias ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) Select(fields ...string) QueryConstructor

+ func (qb *Neo4jQueryConstructor) Where(condition Condition) QueryConstructor

+ func (qb *Neo4jQueryConstructor) WhereAll(conditions ...Condition) QueryConstructor

+ func (qb *Neo4jQueryConstructor) WhereAny(conditions ...Condition) QueryConstructor

+ type Neo4jQueryConstructorProvider struct

+ func NewNeo4jQueryConstructorProvider() *Neo4jQueryConstructorProvider

+ func (p *Neo4jQueryConstructorProvider) GetCapabilities() *QueryBuilderCapabilities

+ func (p *Neo4jQueryConstructorProvider) NewQueryConstructor(schema Schema) QueryConstructor

+ func (p *Neo4jQueryConstructorProvider) SetCompiler(compiler QueryCompiler) *Neo4jQueryConstructorProvider

+ type PhoneNumberValidator struct

+ Locale string

+ func NewPhoneNumberValidatorForLocale(locale string) *PhoneNumberValidator

+ func (v *PhoneNumberValidator) Validate(value interface{}) error

+ func (v *PhoneNumberValidator) ValidateWithLocale(value interface{}, locale string) error

+ type PostalCodeValidator struct

+ Locale string

+ func NewPostalCodeValidatorForLocale(locale string) *PostalCodeValidator

+ func (v *PostalCodeValidator) Validate(value interface{}) error

+ func (v *PostalCodeValidator) ValidateWithLocale(value interface{}, locale string) error

type PostgreSQLAdapter

+ func (a *PostgreSQLAdapter) InspectFullTextRuntime(ctx context.Context) (*FullTextRuntimeCapability, error)

+ func (a *PostgreSQLAdapter) InspectJSONRuntime(ctx context.Context) (*JSONRuntimeCapability, error)

+ func (a *PostgreSQLAdapter) PostgresJSONType() string

+ type PostgreSQLFeatures struct

+ func GetPostgreSQLFeatures(adapter Adapter) (*PostgreSQLFeatures, bool)

+ func (f *PostgreSQLFeatures) CompositeType(typeName string) *CompositeTypeBuilder

+ func (f *PostgreSQLFeatures) DomainType(typeName string) *DomainTypeBuilder

+ func (f *PostgreSQLFeatures) EnumType(typeName string) *EnumTypeBuilder

+ func (f *PostgreSQLFeatures) MaterializedView(viewName string) *PostgreSQLViewBuilder

+ func (f *PostgreSQLFeatures) View(viewName string) *PostgreSQLViewBuilder

+ type PostgreSQLViewBuilder struct

+ func (b *PostgreSQLViewBuilder) Args(args ...interface{}) *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) As(selectSQL string) *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) BuildCreate() (string, error)

+ func (b *PostgreSQLViewBuilder) BuildDrop() (string, error)

+ func (b *PostgreSQLViewBuilder) BuildRefresh() (string, error)

+ func (b *PostgreSQLViewBuilder) Create(ctx context.Context) error

+ func (b *PostgreSQLViewBuilder) CreateOnly() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) CreateOrReplace() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) Drop(ctx context.Context) error

+ func (b *PostgreSQLViewBuilder) DropIfExists() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) DropStrict() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) Refresh(ctx context.Context) error

+ func (b *PostgreSQLViewBuilder) RefreshConcurrently() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) Schema(schema string) *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) WithCheckOption() *PostgreSQLViewBuilder

+ func (b *PostgreSQLViewBuilder) WithNoData() *PostgreSQLViewBuilder

+ type PostgresConnectionConfig struct

+ DSN string

+ Database string

+ Host string

+ Password string

+ Port int

+ SSLMode string

+ Username string

+ type PresetRegistry struct

+ Date DatePresetRegistry

+ type QueryCacheConfig struct

+ DefaultTTLSeconds int

+ EnableMetrics bool

+ MaxEntries int

+ type QueryCompileHints struct

+ TempTable string

+ UseTempTable bool

+ ViewRoute *QueryViewRouteIR

+ type QueryCompiler interface

+ Compile func(ctx context.Context, ir *QueryIR) (string, []interface{}, error)

type QueryConstructor

+ CrossJoin func(table string, alias ...string) QueryConstructor

+ CrossTableStrategy func(strategy CrossTableStrategy) QueryConstructor

+ FromAlias func(alias string) QueryConstructor

+ Join func(table, onClause string, alias ...string) QueryConstructor

+ LeftJoin func(table, onClause string, alias ...string) QueryConstructor

+ RightJoin func(table, onClause string, alias ...string) QueryConstructor

+ type QueryConstructorAutoExecutionResult struct

+ Args []interface{}

+ Exec *QueryConstructorExecSummary

+ Mode string

+ Rows []map[string]interface{}

+ Statement string

+ type QueryConstructorExecSummary struct

+ Counters map[string]int

+ Details map[string]interface{}

+ LastInsertID *int64

+ RowsAffected int64

+ type QueryConstructorExecutionResult struct

+ Args []interface{}

+ Rows []map[string]interface{}

+ Statement string

type QueryFallbackStrategy

+ const QueryFallbackCustomFunction

type QueryFeatures

+ func NewNeo4jQueryFeatures() *QueryFeatures

+ type QueryIR struct

+ Conditions []Condition

+ CrossTableStrategy CrossTableStrategy

+ Hints QueryCompileHints

+ Joins []QueryJoinIR

+ Limit *int

+ Offset *int

+ OrderBys []QueryOrderIR

+ Projections []string

+ Source QuerySourceIR

+ type QueryJoinIR struct

+ Alias string

+ JoinType string

+ OnClause string

+ Table string

+ type QueryOrderIR struct

+ Direction string

+ Field string

+ type QuerySourceIR struct

+ Alias string

+ Table string

+ type QueryViewRouteIR struct

+ Alias string

+ ViewName string

+ type RangeValidator struct

+ Max *float64

+ Min *float64

+ func NewMaxRangeValidator(max float64) *RangeValidator

+ func NewMinRangeValidator(min float64) *RangeValidator

+ func NewRangeValidator(min, max float64) *RangeValidator

+ func (v *RangeValidator) Validate(value interface{}) error

+ type RecursiveQueryBuilder struct

+ func (b *RecursiveQueryBuilder) Anchor(sql string) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) Build() (string, error)

+ func (b *RecursiveQueryBuilder) Columns(cols ...string) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) Execute(ctx context.Context) (*sql.Rows, error)

+ func (b *RecursiveQueryBuilder) MaxRecursion(n int) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) OrderBy(expr string) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) Recursive(sql string) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) ScanRows(ctx context.Context) ([]map[string]interface{}, error)

+ func (b *RecursiveQueryBuilder) Select(selectExpr string) *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) SelectAll() *RecursiveQueryBuilder

+ func (b *RecursiveQueryBuilder) Where(condition string, args ...interface{}) *RecursiveQueryBuilder

+ type RegexValidator struct

+ Code string

+ InvalidType string

+ InvalidValue string

+ Pattern string

+ func (v *RegexValidator) Validate(value interface{}) error

type Repository

+ func (r *Repository) AnalyzeFuzzySearch(ctx context.Context, field, keyword, version string) (*FuzzySearchPlan, error)

+ func (r *Repository) BuildAndCacheQuery(ctx context.Context, cacheKey string, constructor QueryConstructor) (query string, args []interface{}, cacheHit bool, err error)

+ func (r *Repository) BuildAndCacheQueryTemplate(ctx context.Context, cacheKey string, constructor QueryConstructor) (query string, argCount int, cacheHit bool, err error)

+ func (r *Repository) BuildFuzzyCondition(field, keyword, version string) Condition

+ func (r *Repository) BuildFuzzyConditionWithContext(ctx context.Context, field, keyword, version string) (Condition, error)

+ func (r *Repository) ClearCompiledQueryCache()

+ func (r *Repository) DecideFeatureExecution(feature, version string) (*FeatureExecutionDecision, error)

+ func (r *Repository) ExecCypher(ctx context.Context, cypher string, params map[string]interface{}) (*CypherWriteSummary, error)

+ func (r *Repository) ExecWithCachedTemplate(ctx context.Context, cacheKey string, args ...interface{}) (sql.Result, error)

+ func (r *Repository) ExecuteFeature(ctx context.Context, feature, version string, input map[string]interface{}) (interface{}, error)

+ func (r *Repository) ExecuteQueryConstructor(ctx context.Context, constructor QueryConstructor) (*QueryConstructorExecutionResult, error)

+ func (r *Repository) ExecuteQueryConstructorAuto(ctx context.Context, constructor QueryConstructor) (*QueryConstructorAutoExecutionResult, error)

+ func (r *Repository) ExecuteQueryConstructorWithCache(ctx context.Context, cacheKey string, constructor QueryConstructor) (*QueryConstructorExecutionResult, bool, error)

+ func (r *Repository) GetCompiledQuery(cacheKey string) (*CompiledQuery, bool)

+ func (r *Repository) GetCompiledQueryCacheStats() CompiledQueryCacheStats

+ func (r *Repository) GetCompiledQueryTemplate(cacheKey string) (*CompiledQueryTemplate, bool)

+ func (r *Repository) GetQueryBuilderCapabilities() (*QueryBuilderCapabilities, error)

+ func (r *Repository) GetStartupCapabilityReport() *StartupCapabilityReport

+ func (r *Repository) InvalidateCompiledQuery(cacheKey string)

+ func (r *Repository) NewChangesetExecutor(ctx context.Context, schema Schema) (*ChangesetExecutor, error)

+ func (r *Repository) NewQueryConstructor(schema Schema) (QueryConstructor, error)

+ func (r *Repository) QueryCypher(ctx context.Context, cypher string, params map[string]interface{}) ([]map[string]interface{}, error)

+ func (r *Repository) QueryRowWithCachedTemplate(ctx context.Context, cacheKey string, args ...interface{}) (*sql.Row, error)

+ func (r *Repository) QueryWithCachedTemplate(ctx context.Context, cacheKey string, args ...interface{}) (*sql.Rows, error)

+ func (r *Repository) RunStartupCapabilityCheck(ctx context.Context, cfg *StartupCapabilityConfig) (*StartupCapabilityReport, error)

+ func (r *Repository) StoreCompiledQuery(cacheKey string, query string, args ...interface{}) error

+ func (r *Repository) StoreCompiledQueryTemplate(cacheKey string, query string, argCount int) error

+ func (r *Repository) WithChangeset(ctx context.Context, schema Schema, fn func(*ChangesetExecutor) error) error

type SQLQueryConstructor

+ func NewSQLQueryConstructorWithCompiler(schema Schema, dialect SQLDialect, compiler QueryCompiler) *SQLQueryConstructor

+ func (qb *SQLQueryConstructor) BuildIR(ctx context.Context) (*QueryIR, error)

+ func (qb *SQLQueryConstructor) CrossJoin(table string, alias ...string) QueryConstructor

+ func (qb *SQLQueryConstructor) CrossTableStrategy(strategy CrossTableStrategy) QueryConstructor

+ func (qb *SQLQueryConstructor) FromAlias(alias string) QueryConstructor

+ func (qb *SQLQueryConstructor) Join(table, onClause string, alias ...string) QueryConstructor

+ func (qb *SQLQueryConstructor) LeftJoin(table, onClause string, alias ...string) QueryConstructor

+ func (qb *SQLQueryConstructor) RightJoin(table, onClause string, alias ...string) QueryConstructor

type SQLServerAdapter

+ func (a *SQLServerAdapter) InspectFullTextRuntime(ctx context.Context) (*FullTextRuntimeCapability, error)

+ func (a *SQLServerAdapter) InspectJSONRuntime(ctx context.Context) (*JSONRuntimeCapability, error)

+ type SQLServerConnectionConfig struct

+ DSN string

+ Database string

+ Host string

+ Password string

+ Port int

+ Username string

+ type SQLServerDynamicTableHook struct

+ func NewSQLServerDynamicTableHook(adapter *SQLServerAdapter) *SQLServerDynamicTableHook

+ func (h *SQLServerDynamicTableHook) CreateDynamicTable(ctx context.Context, configName string, params map[string]interface{}) (string, error)

+ func (h *SQLServerDynamicTableHook) GetDynamicTableConfig(ctx context.Context, configName string) (*DynamicTableConfig, error)

+ func (h *SQLServerDynamicTableHook) ListCreatedDynamicTables(ctx context.Context, configName string) ([]string, error)

+ func (h *SQLServerDynamicTableHook) ListDynamicTableConfigs(ctx context.Context) ([]*DynamicTableConfig, error)

+ func (h *SQLServerDynamicTableHook) RegisterDynamicTable(ctx context.Context, config *DynamicTableConfig) error

+ func (h *SQLServerDynamicTableHook) UnregisterDynamicTable(ctx context.Context, configName string) error

+ type SQLServerFeatures struct

+ func GetSQLServerFeatures(adapter Adapter) (*SQLServerFeatures, bool)

+ func (f *SQLServerFeatures) MergeInto(targetTable string) *SQLServerMergeBuilder

+ func (f *SQLServerFeatures) RecursiveQuery(cteName string) *RecursiveQueryBuilder

+ func (f *SQLServerFeatures) TempTable(name string) *SQLServerTempTableBuilder

+ func (f *SQLServerFeatures) View(name string) *SQLServerViewBuilder

+ type SQLServerMergeBuilder struct

+ func (b *SQLServerMergeBuilder) Args(args ...interface{}) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) Build() (string, error)

+ func (b *SQLServerMergeBuilder) DisableHoldLock() *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) Execute(ctx context.Context) (sql.Result, error)

+ func (b *SQLServerMergeBuilder) On(condition string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) Output(outputExpr string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) Query(ctx context.Context) (*sql.Rows, error)

+ func (b *SQLServerMergeBuilder) SourceAlias(alias string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) TargetAlias(alias string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) Using(sourceSQL string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) WhenMatchedUpdate(setClause string) *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) WhenNotMatchedBySourceDelete() *SQLServerMergeBuilder

+ func (b *SQLServerMergeBuilder) WhenNotMatchedInsert(columns []string, valuesExpr string) *SQLServerMergeBuilder

+ type SQLServerTempTableBuilder struct

+ func (b *SQLServerTempTableBuilder) Args(args ...interface{}) *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) AsSelect(selectSQL string) *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) BuildCreate() (string, error)

+ func (b *SQLServerTempTableBuilder) BuildDrop() string

+ func (b *SQLServerTempTableBuilder) Column(name, dataType string, nullable bool) *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) Drop(ctx context.Context) error

+ func (b *SQLServerTempTableBuilder) DropIfExists() *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) ExecuteCreate(ctx context.Context) error

+ func (b *SQLServerTempTableBuilder) Global() *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) KeepIfExists() *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) Local() *SQLServerTempTableBuilder

+ func (b *SQLServerTempTableBuilder) TempTableName() string

+ type SQLServerTempTableColumn struct

+ Name string

+ Nullable bool

+ Type string

+ type SQLServerViewBuilder struct

+ func (b *SQLServerViewBuilder) Args(args ...interface{}) *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) As(selectSQL string) *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) BuildCreate() (string, error)

+ func (b *SQLServerViewBuilder) BuildDrop() (string, error)

+ func (b *SQLServerViewBuilder) CreateOnly() *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) CreateOrAlter() *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) Drop(ctx context.Context) error

+ func (b *SQLServerViewBuilder) DropIfExists() *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) DropStrict() *SQLServerViewBuilder

+ func (b *SQLServerViewBuilder) ExecuteCreate(ctx context.Context) error

+ func (b *SQLServerViewBuilder) WithCheckOption() *SQLServerViewBuilder

type SQLiteAdapter

+ func (a *SQLiteAdapter) InspectFullTextRuntime(ctx context.Context) (*FullTextRuntimeCapability, error)

+ type SQLiteConnectionConfig struct

+ DSN string

+ Path string

+ type ShardingRiskLevel string

+ const ShardingRiskHigh

+ const ShardingRiskLow

+ const ShardingRiskMedium

+ type ShardingStabilityReport struct

+ Deterministic bool

+ Errors []string

+ HotShards []string

+ Recommendations []string

+ RiskLevel ShardingRiskLevel

+ SampleCount int

+ ShardLoads map[string]int

+ TemplateKind ShardingTemplateKind

+ UniqueShards []string

+ Warnings []string

+ func (r *ShardingStabilityReport) CanRelease() bool

+ func (r *ShardingStabilityReport) ReleaseBlockReasons() []string

+ type ShardingStabilityTool struct

+ func NewShardingStabilityTool() *ShardingStabilityTool

+ func (t *ShardingStabilityTool) ValidateShardNaming(baseTableName string, shardIDs []string) []error

+ func (t *ShardingStabilityTool) ValidateTemplate(template *AutoShardingTemplate, samples []map[string]interface{}, ...) *ShardingStabilityReport

+ type ShardingTemplateKind string

+ const ShardingByDataScale

+ const ShardingByDate

+ const ShardingByRegion

+ type StartupCapabilityCheck struct

+ EffectiveMode string

+ Error string

+ InspectorAvailable bool

+ Name string

+ Notes string

+ Required bool

+ Status string

+ Supported bool

+ type StartupCapabilityConfig struct

+ CapabilityModes map[string]string

+ Inspect []string

+ Mode string

+ Required []string

+ type StartupCapabilityReport struct

+ Adapter string

+ Checks []StartupCapabilityCheck

+ GeneratedAt string

+ Mode string

+ type TTLIndexInfo struct

+ ExpireAfter time.Duration

+ Field string

+ Name string

+ type TableConstraint struct

+ Fields []string

+ Kind ConstraintKind

+ Name string

+ OnDelete string

+ OnUpdate string

+ RefFields []string

+ RefTable string

+ ViewHint *ViewHint

+ type URLValidator struct

+ Locale string

+ func NewURLValidatorForLocale(locale string) *URLValidator

+ func (v *URLValidator) Validate(value interface{}) error

+ func (v *URLValidator) ValidateWithLocale(value interface{}, locale string) error

+ type ValidationConfig struct

+ DefaultLocale string

+ EnabledLocales []string

+ type ValidationMessages struct

+ EmailInvalidType string

+ EmailInvalidValue string

+ IDCardInvalidType string

+ IDCardInvalidValue string

+ PhoneInvalidType string

+ PhoneInvalidValue string

+ PostalInvalidType string

+ PostalInvalidValue string

+ URLInvalidType string

+ URLInvalidValue string

+ type ValidationProfile struct

+ EmailPattern string

+ IDCardPattern string

+ Locale string

+ Messages ValidationMessages

+ PhonePattern string

+ PostalCodePattern string

+ URLPattern string

+ type ViewBuilder struct

+ func (b *ViewBuilder) Args(args ...interface{}) *ViewBuilder

+ func (b *ViewBuilder) As(selectSQL string) *ViewBuilder

+ func (b *ViewBuilder) BuildCreate() (string, error)

+ func (b *ViewBuilder) BuildDrop() (string, error)

+ func (b *ViewBuilder) CreateOnly() *ViewBuilder

+ func (b *ViewBuilder) CreateOrAlter() *ViewBuilder

+ func (b *ViewBuilder) Drop(ctx context.Context) error

+ func (b *ViewBuilder) DropIfExists() *ViewBuilder

+ func (b *ViewBuilder) DropStrict() *ViewBuilder

+ func (b *ViewBuilder) ExecuteCreate(ctx context.Context) error

+ func (b *ViewBuilder) Materialized() *ViewBuilder

+ func (b *ViewBuilder) WithCheckOption() *ViewBuilder

+ type ViewFeatures struct

+ func GetViewFeatures(adapter Adapter) (*ViewFeatures, bool)

+ func (f *ViewFeatures) View(name string) *ViewBuilder

+ type ViewHint struct

+ Columns []string

+ JoinType string

+ Materialized bool

+ ViewName string

v1.0.0-rc.1

Mar 18, 2026

v0

v0.4.4-preview

Feb 4, 2026

v0.4.3

Feb 4, 2026

Changes in this version

+ var GraphDatabaseSupport = &RelationshipSupport

+ var MongoDBSupport = &RelationshipSupport

+ var MySQLSupport = &RelationshipSupport

+ var NoRelationshipSupport = &RelationshipSupport

+ var PostgreSQLSupport = &RelationshipSupport

+ var SQLServerSupport = &RelationshipSupport

+ var SQLiteSupport = &RelationshipSupport

+ func CompareQueryFeatures(qf1, qf2 *QueryFeatures) map[string]interface

+ func ConvertValue(value interface{}, targetType FieldType) (interface{}, error)

+ func ExampleMySQLDynamicTable()

+ func ExamplePostgreSQLDynamicTable()

+ func ExampleSQLiteDynamicTable()

+ func GetStructFields(v interface{}) []string

+ func GetStructValues(v interface{}) []interface

+ func LoadAdapterRegistry(filename string) (map[string]*Config, error)

+ func PrintQueryFeatureMatrix(databases ...string) string

+ func RealWorldExample(repo *Repository, ctx context.Context) error

+ func RegisterAdapter(factory AdapterFactory)

+ func RegisterAdapterConfig(name string, config *Config) error

+ func RegisterAdapterConfigs(configs map[string]*Config) error

+ func RegisterAdapterConstructor(name string, ctor interface{}) error

+ func RegisterCustomSQLiteDriver(driverName string, functions map[string]interface{}) error

+ func SaveConfig(filename string, config *Config) error

+ func ScanStruct(row *sql.Row, dest interface{}) error

+ func ScanStructs(rows *sql.Rows, dest interface{}) error

+ func Timestamp() time.Time

+ type Action string

+ const ActionDelete

+ const ActionInsert

+ const ActionUpdate

+ type Adapter interface

+ Begin func(ctx context.Context, opts ...interface{}) (Tx, error)

+ Close func() error

+ Connect func(ctx context.Context, config *Config) error

+ Exec func(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

+ GetDatabaseFeatures func() *DatabaseFeatures

+ GetQueryBuilderProvider func() QueryConstructorProvider

+ GetQueryFeatures func() *QueryFeatures

+ GetRawConn func() interface{}

+ ListScheduledTasks func(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ Ping func(ctx context.Context) error

+ Query func(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) *sql.Row

+ RegisterScheduledTask func(ctx context.Context, task *ScheduledTaskConfig) error

+ UnregisterScheduledTask func(ctx context.Context, taskName string) error

+ type AdapterFactory interface

+ Create func(config *Config) (Adapter, error)

+ Name func() string

+ type AdapterRegistryFile struct

+ Adapters map[string]*Config

+ type BaseMigration struct

+ func NewBaseMigration(version, description string) *BaseMigration

+ func (m *BaseMigration) Description() string

+ func (m *BaseMigration) Version() string

+ type BaseSchema struct

+ func InferSchema(v interface{}) (*BaseSchema, error)

+ func NewBaseSchema(tableName string) *BaseSchema

+ func (s *BaseSchema) AddField(field *Field) *BaseSchema

+ func (s *BaseSchema) Fields() []*Field

+ func (s *BaseSchema) GetField(name string) *Field

+ func (s *BaseSchema) PrimaryKeyField() *Field

+ func (s *BaseSchema) TableName() string

+ type Changeset struct

+ func FromMap(schema Schema, dataMap map[string]interface{}) *Changeset

+ func NewChangeset(schema Schema) *Changeset

+ func (cs *Changeset) ApplyAction(action Action) *Changeset

+ func (cs *Changeset) Cast(data map[string]interface{}) *Changeset

+ func (cs *Changeset) Changes() map[string]interface{}

+ func (cs *Changeset) ClearError(fieldName string) *Changeset

+ func (cs *Changeset) Data() map[string]interface{}

+ func (cs *Changeset) ErrorString() string

+ func (cs *Changeset) Errors() map[string][]string

+ func (cs *Changeset) ForceChanges() *Changeset

+ func (cs *Changeset) Get(fieldName string) interface{}

+ func (cs *Changeset) GetChange(fieldName string) interface{}

+ func (cs *Changeset) GetChanged(fieldName string) (interface{}, bool)

+ func (cs *Changeset) GetChangedFields() []string

+ func (cs *Changeset) GetError(fieldName string) []string

+ func (cs *Changeset) GetPrevious(fieldName string) interface{}

+ func (cs *Changeset) HasChanged(fieldName string) bool

+ func (cs *Changeset) IsValid() bool

+ func (cs *Changeset) PutChange(fieldName string, value interface{}) *Changeset

+ func (cs *Changeset) ToMap() map[string]interface{}

+ func (cs *Changeset) Validate() *Changeset

+ func (cs *Changeset) ValidateChange(fieldName string, validator Validator) *Changeset

+ func (cs *Changeset) ValidateExclusion(fieldName string, list []interface{}) *Changeset

+ func (cs *Changeset) ValidateFormat(fieldName string, pattern string, message ...string) *Changeset

+ func (cs *Changeset) ValidateInclusion(fieldName string, list []interface{}) *Changeset

+ func (cs *Changeset) ValidateLength(fieldName string, min, max int) *Changeset

+ func (cs *Changeset) ValidateNumber(fieldName string, opts map[string]interface{}) *Changeset

+ func (cs *Changeset) ValidateRequired(fields []string) *Changeset

+ type CompositeCondition struct

+ Conditions []Condition

+ Operator string

+ func (c *CompositeCondition) Translate(translator ConditionTranslator) (string, []interface{}, error)

+ func (c *CompositeCondition) Type() string

+ type Condition interface

+ Translate func(translator ConditionTranslator) (string, []interface{}, error)

+ Type func() string

+ func And(conditions ...Condition) Condition

+ func Between(field string, min, max interface{}) Condition

+ func Eq(field string, value interface{}) Condition

+ func Gt(field string, value interface{}) Condition

+ func Gte(field string, value interface{}) Condition

+ func In(field string, values ...interface{}) Condition

+ func Like(field string, pattern string) Condition

+ func Lt(field string, value interface{}) Condition

+ func Lte(field string, value interface{}) Condition

+ func Ne(field string, value interface{}) Condition

+ func Not(condition Condition) Condition

+ func Or(conditions ...Condition) Condition

+ type ConditionBuilder struct

+ type ConditionTranslator interface

+ TranslateComposite func(operator string, conditions []Condition) (string, []interface{}, error)

+ TranslateCondition func(condition Condition) (string, []interface{}, error)

+ type Config struct

+ Adapter string

+ Database string

+ Host string

+ Options map[string]interface{}

+ Password string

+ Pool *PoolConfig

+ Port int

+ SSLMode string

+ Username string

+ func DefaultConfig(adapterType string) *Config

+ func GetAdapterConfig(name string) (*Config, bool)

+ func LoadConfig(filename string) (*Config, error)

+ func LoadConfigWithDefaults(filename string, defaults *Config) (*Config, error)

+ func (c *Config) Validate() error

+ type ConfigFile struct

+ Database *Config

+ type DatabaseFeatures struct

+ DatabaseName string

+ DatabaseVersion string

+ Description string

+ FullTextLanguages []string

+ FunctionLanguages []string

+ HasNativeJSON bool

+ SupportsAggregateFuncs bool

+ SupportsArrays bool

+ SupportsCTE bool

+ SupportsCompositeIndexes bool

+ SupportsCompositeKeys bool

+ SupportsCompositeType bool

+ SupportsDeferrable bool

+ SupportsDomainType bool

+ SupportsEnumType bool

+ SupportsFullTextSearch bool

+ SupportsFunctions bool

+ SupportsGenerated bool

+ SupportsJSONIndex bool

+ SupportsJSONPath bool

+ SupportsListenNotify bool

+ SupportsMaterializedCTE bool

+ SupportsPartialIndexes bool

+ SupportsRecursiveCTE bool

+ SupportsReturning bool

+ SupportsStoredProcedures bool

+ SupportsUDT bool

+ SupportsUpsert bool

+ SupportsWindowFunctions bool

+ func NewMongoDatabaseFeatures() *DatabaseFeatures

+ func (f *DatabaseFeatures) GetFeaturesByCategory(category FeatureCategory) []string

+ func (f *DatabaseFeatures) HasFeature(feature string) bool

+ type DefaultSQLDialect struct

+ func (d *DefaultSQLDialect) GenerateLimitOffset(limit *int, offset *int) string

+ func (d *DefaultSQLDialect) GetPlaceholder(index int) string

+ func (d *DefaultSQLDialect) Name() string

+ func (d *DefaultSQLDialect) QuoteIdentifier(name string) string

+ func (d *DefaultSQLDialect) QuoteValue(value interface{}) string

+ func (d *DefaultSQLDialect) TranslateCondition(condition Condition, argIndex *int) (string, []interface{}, error)

+ type DefaultSQLQueryConstructorProvider struct

+ func NewDefaultSQLQueryConstructorProvider(dialect SQLDialect) *DefaultSQLQueryConstructorProvider

+ func (p *DefaultSQLQueryConstructorProvider) GetCapabilities() *QueryBuilderCapabilities

+ func (p *DefaultSQLQueryConstructorProvider) NewQueryConstructor(schema Schema) QueryConstructor

+ type DefaultSQLTranslator struct

+ func (t *DefaultSQLTranslator) TranslateComposite(operator string, conditions []Condition) (string, []interface{}, error)

+ func (t *DefaultSQLTranslator) TranslateCondition(condition Condition) (string, []interface{}, error)

+ type DynamicTableConfig struct

+ Description string

+ Fields []*DynamicTableField

+ Options map[string]interface{}

+ ParentTable string

+ Strategy string

+ TableName string

+ TriggerCondition string

+ func NewDynamicTableConfig(tableName string) *DynamicTableConfig

+ func (c *DynamicTableConfig) AddField(field *DynamicTableField) *DynamicTableConfig

+ func (c *DynamicTableConfig) WithDescription(desc string) *DynamicTableConfig

+ func (c *DynamicTableConfig) WithOption(key string, value interface{}) *DynamicTableConfig

+ func (c *DynamicTableConfig) WithParentTable(parentTable, triggerCondition string) *DynamicTableConfig

+ func (c *DynamicTableConfig) WithStrategy(strategy string) *DynamicTableConfig

+ type DynamicTableField struct

+ Autoinc bool

+ Default interface{}

+ Description string

+ Index bool

+ Name string

+ Null bool

+ Primary bool

+ Type FieldType

+ Unique bool

+ func NewDynamicTableField(name string, fieldType FieldType) *DynamicTableField

+ func (f *DynamicTableField) AsNotNull() *DynamicTableField

+ func (f *DynamicTableField) AsPrimaryKey() *DynamicTableField

+ func (f *DynamicTableField) WithAutoinc() *DynamicTableField

+ func (f *DynamicTableField) WithDefault(value interface{}) *DynamicTableField

+ func (f *DynamicTableField) WithDescription(desc string) *DynamicTableField

+ func (f *DynamicTableField) WithIndex() *DynamicTableField

+ func (f *DynamicTableField) WithUnique() *DynamicTableField

+ type DynamicTableHook interface

+ CreateDynamicTable func(ctx context.Context, configName string, params map[string]interface{}) (string, error)

+ GetDynamicTableConfig func(ctx context.Context, configName string) (*DynamicTableConfig, error)

+ ListCreatedDynamicTables func(ctx context.Context, configName string) ([]string, error)

+ ListDynamicTableConfigs func(ctx context.Context) ([]*DynamicTableConfig, error)

+ RegisterDynamicTable func(ctx context.Context, config *DynamicTableConfig) error

+ UnregisterDynamicTable func(ctx context.Context, configName string) error

+ type DynamicTableRegistry struct

+ func NewDynamicTableRegistry() *DynamicTableRegistry

+ func (r *DynamicTableRegistry) Get(name string) (*DynamicTableConfig, error)

+ func (r *DynamicTableRegistry) List() []*DynamicTableConfig

+ func (r *DynamicTableRegistry) Register(name string, config *DynamicTableConfig) error

+ func (r *DynamicTableRegistry) Unregister(name string) error

+ type EmailValidator struct

+ func (v *EmailValidator) Validate(value interface{}) error

+ type FeatureCategory string

+ const CategoryAdvanced

+ const CategoryFullText

+ const CategoryFunctions

+ const CategoryIndexing

+ const CategoryJSON

+ const CategoryOther

+ const CategoryTypes

+ type FeatureComparison struct

+ CommonFeatures []string

+ Database1 string

+ Database2 string

+ OnlyInFirst []string

+ OnlyInSecond []string

+ func CompareFeatures(f1, f2 *DatabaseFeatures) *FeatureComparison

+ type FeatureFallback string

+ const FallbackApplicationLayer

+ const FallbackCheckConstraint

+ const FallbackDynamicTable

+ const FallbackNone

+ type FeatureSupport struct

+ MinVersion string

+ Notes string

+ Supported bool

+ type Field struct

+ Autoinc bool

+ Default interface{}

+ Index bool

+ Name string

+ Null bool

+ Primary bool

+ Transformers []Transformer

+ Type FieldType

+ Unique bool

+ Validators []Validator

+ type FieldBuilder struct

+ func NewField(name string, fieldType FieldType) *FieldBuilder

+ func (fb *FieldBuilder) Build() *Field

+ func (fb *FieldBuilder) Default(value interface{}) *FieldBuilder

+ func (fb *FieldBuilder) Index() *FieldBuilder

+ func (fb *FieldBuilder) Null(allow bool) *FieldBuilder

+ func (fb *FieldBuilder) PrimaryKey() *FieldBuilder

+ func (fb *FieldBuilder) Transform(transformer Transformer) *FieldBuilder

+ func (fb *FieldBuilder) Unique() *FieldBuilder

+ func (fb *FieldBuilder) Validate(validator Validator) *FieldBuilder

+ type FieldType string

+ const TypeArray

+ const TypeBinary

+ const TypeBoolean

+ const TypeDecimal

+ const TypeFloat

+ const TypeInteger

+ const TypeJSON

+ const TypeMap

+ const TypeString

+ const TypeTime

+ type ForeignKeyAction string

+ const ActionCascade

+ const ActionNoAction

+ const ActionRestrict

+ const ActionSetNull

+ type ForeignKeyDef struct

+ FromColumn string

+ OnDelete ForeignKeyAction

+ OnUpdate ForeignKeyAction

+ ToColumn string

+ type JoinTableDef struct

+ ExtraColumns []*Field

+ FromForeignKey string

+ TableName string

+ ToForeignKey string

+ type LengthValidator struct

+ Max int

+ Min int

+ func (v *LengthValidator) Validate(value interface{}) error

+ type LowercaseTransformer struct

+ func (t *LowercaseTransformer) Transform(value interface{}) (interface{}, error)

+ type MaxLengthValidator struct

+ Length int

+ func (v *MaxLengthValidator) Validate(value interface{}) error

+ type Migration struct

+ Description string

+ DownSQL []string

+ UpSQL []string

+ Version string

+ type MigrationInterface interface

+ Description func() string

+ Down func(ctx context.Context, repo *Repository) error

+ Up func(ctx context.Context, repo *Repository) error

+ Version func() string

+ type MigrationLog struct

+ ExecutedAt time.Time

+ ID int64

+ RunOn time.Time

+ Version string

+ type MigrationRunner struct

+ func NewMigrationRunner(repo *Repository) *MigrationRunner

+ func (r *MigrationRunner) Down(ctx context.Context) error

+ func (r *MigrationRunner) Register(migration MigrationInterface)

+ func (r *MigrationRunner) Status(ctx context.Context) ([]MigrationStatus, error)

+ func (r *MigrationRunner) Up(ctx context.Context) error

+ type MigrationStatus struct

+ Applied bool

+ AppliedAt time.Time

+ Description string

+ Version string

+ type Migrator struct

+ func NewMigrator(repo *Repository) *Migrator

+ func (m *Migrator) Down(ctx context.Context) error

+ func (m *Migrator) Register(migration *Migration) error

+ func (m *Migrator) Status(ctx context.Context) ([]map[string]interface{}, error)

+ func (m *Migrator) Up(ctx context.Context) error

+ type MinLengthValidator struct

+ Length int

+ func (v *MinLengthValidator) Validate(value interface{}) error

+ type MongoAdapter struct

+ func NewMongoAdapter(config *Config) (*MongoAdapter, error)

+ func (a *MongoAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *MongoAdapter) Close() error

+ func (a *MongoAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *MongoAdapter) Exec(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

+ func (a *MongoAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *MongoAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *MongoAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *MongoAdapter) GetRawConn() interface{}

+ func (a *MongoAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *MongoAdapter) Ping(ctx context.Context) error

+ func (a *MongoAdapter) Query(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

+ func (a *MongoAdapter) QueryRow(ctx context.Context, sql string, args ...interface{}) *sql.Row

+ func (a *MongoAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *MongoAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type MongoFactory struct

+ func (f *MongoFactory) Create(config *Config) (Adapter, error)

+ func (f *MongoFactory) Name() string

+ type MySQLAdapter struct

+ func (a *MySQLAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *MySQLAdapter) Close() error

+ func (a *MySQLAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *MySQLAdapter) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (a *MySQLAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *MySQLAdapter) GetGormDB() *gorm.DB

+ func (a *MySQLAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *MySQLAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *MySQLAdapter) GetRawConn() interface{}

+ func (a *MySQLAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *MySQLAdapter) Ping(ctx context.Context) error

+ func (a *MySQLAdapter) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (a *MySQLAdapter) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (a *MySQLAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *MySQLAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type MySQLDialect struct

+ func NewMySQLDialect() *MySQLDialect

+ type MySQLDynamicTableHook struct

+ func NewMySQLDynamicTableHook(adapter *MySQLAdapter) *MySQLDynamicTableHook

+ func (h *MySQLDynamicTableHook) CreateDynamicTable(ctx context.Context, configName string, params map[string]interface{}) (string, error)

+ func (h *MySQLDynamicTableHook) GetDynamicTableConfig(ctx context.Context, configName string) (*DynamicTableConfig, error)

+ func (h *MySQLDynamicTableHook) ListCreatedDynamicTables(ctx context.Context, configName string) ([]string, error)

+ func (h *MySQLDynamicTableHook) ListDynamicTableConfigs(ctx context.Context) ([]*DynamicTableConfig, error)

+ func (h *MySQLDynamicTableHook) RegisterDynamicTable(ctx context.Context, config *DynamicTableConfig) error

+ func (h *MySQLDynamicTableHook) UnregisterDynamicTable(ctx context.Context, configName string) error

+ type MySQLFactory struct

+ func (f *MySQLFactory) Create(config *Config) (Adapter, error)

+ func (f *MySQLFactory) Name() string

+ type MySQLTx struct

+ func (t *MySQLTx) Commit(ctx context.Context) error

+ func (t *MySQLTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *MySQLTx) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *MySQLTx) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *MySQLTx) Rollback(ctx context.Context) error

+ type NotCondition struct

+ Condition Condition

+ func (c *NotCondition) Translate(translator ConditionTranslator) (string, []interface{}, error)

+ func (c *NotCondition) Type() string

+ type OrderBy struct

+ Direction string

+ Field string

+ type PatternValidator struct

+ Pattern string

+ func (v *PatternValidator) Validate(value interface{}) error

+ type PoolConfig struct

+ ConnectTimeout int

+ IdleTimeout int

+ MaxConnections int

+ MaxLifetime int

+ MinConnections int

+ type PostgreSQLAdapter struct

+ func (a *PostgreSQLAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *PostgreSQLAdapter) Close() error

+ func (a *PostgreSQLAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *PostgreSQLAdapter) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (a *PostgreSQLAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *PostgreSQLAdapter) GetGormDB() *gorm.DB

+ func (a *PostgreSQLAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *PostgreSQLAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *PostgreSQLAdapter) GetRawConn() interface{}

+ func (a *PostgreSQLAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *PostgreSQLAdapter) Ping(ctx context.Context) error

+ func (a *PostgreSQLAdapter) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (a *PostgreSQLAdapter) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (a *PostgreSQLAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *PostgreSQLAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type PostgreSQLDialect struct

+ func NewPostgreSQLDialect() *PostgreSQLDialect

+ func (d *PostgreSQLDialect) GetPlaceholder(index int) string

+ func (d *PostgreSQLDialect) QuoteIdentifier(name string) string

+ type PostgreSQLDynamicTableHook struct

+ func NewPostgreSQLDynamicTableHook(adapter *PostgreSQLAdapter) *PostgreSQLDynamicTableHook

+ func (h *PostgreSQLDynamicTableHook) CreateDynamicTable(ctx context.Context, configName string, params map[string]interface{}) (string, error)

+ func (h *PostgreSQLDynamicTableHook) GetDynamicTableConfig(ctx context.Context, configName string) (*DynamicTableConfig, error)

+ func (h *PostgreSQLDynamicTableHook) ListCreatedDynamicTables(ctx context.Context, configName string) ([]string, error)

+ func (h *PostgreSQLDynamicTableHook) ListDynamicTableConfigs(ctx context.Context) ([]*DynamicTableConfig, error)

+ func (h *PostgreSQLDynamicTableHook) RegisterDynamicTable(ctx context.Context, config *DynamicTableConfig) error

+ func (h *PostgreSQLDynamicTableHook) UnregisterDynamicTable(ctx context.Context, configName string) error

+ type PostgreSQLFactory struct

+ func (f *PostgreSQLFactory) Create(config *Config) (Adapter, error)

+ func (f *PostgreSQLFactory) Name() string

+ type PostgreSQLTx struct

+ func (t *PostgreSQLTx) Commit(ctx context.Context) error

+ func (t *PostgreSQLTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *PostgreSQLTx) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *PostgreSQLTx) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *PostgreSQLTx) Rollback(ctx context.Context) error

+ type QueryBuilder struct

+ func NewQueryBuilder(schema Schema, repo *Repository) *QueryBuilder

+ func (qb *QueryBuilder) Delete(whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (qb *QueryBuilder) DeleteByID(id interface{}) (sql.Result, error)

+ func (qb *QueryBuilder) Insert(cs *Changeset) (sql.Result, error)

+ func (qb *QueryBuilder) Query() *QueryChain

+ func (qb *QueryBuilder) Select(columns string, whereClause string, whereArgs ...interface{}) (*sql.Rows, error)

+ func (qb *QueryBuilder) SelectAll() (*sql.Rows, error)

+ func (qb *QueryBuilder) SelectByID(id interface{}) (*sql.Row, error)

+ func (qb *QueryBuilder) SelectCount(whereClause string, whereArgs ...interface{}) (int64, error)

+ func (qb *QueryBuilder) SelectOne(whereClause string, whereArgs ...interface{}) (*sql.Row, error)

+ func (qb *QueryBuilder) SoftDelete(whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (qb *QueryBuilder) SoftDeleteByID(id interface{}) (sql.Result, error)

+ func (qb *QueryBuilder) Transaction(fn func(*QueryBuilder) error) error

+ func (qb *QueryBuilder) Update(cs *Changeset, whereClause string, whereArgs ...interface{}) (sql.Result, error)

+ func (qb *QueryBuilder) UpdateByID(id interface{}, cs *Changeset) (sql.Result, error)

+ func (qb *QueryBuilder) WithContext(ctx context.Context) *QueryBuilder

+ type QueryBuilderCapabilities struct

+ Description string

+ NativeQueryLang string

+ SupportsAnd bool

+ SupportsBetween bool

+ SupportsEq bool

+ SupportsGt bool

+ SupportsGte bool

+ SupportsIn bool

+ SupportsIndex bool

+ SupportsJoin bool

+ SupportsLike bool

+ SupportsLimit bool

+ SupportsLt bool

+ SupportsLte bool

+ SupportsNativeQuery bool

+ SupportsNe bool

+ SupportsNot bool

+ SupportsOffset bool

+ SupportsOr bool

+ SupportsOrderBy bool

+ SupportsQueryPlan bool

+ SupportsSelect bool

+ SupportsSubquery bool

+ func DefaultQueryBuilderCapabilities() *QueryBuilderCapabilities

+ type QueryChain struct

+ func (qc *QueryChain) All() (*sql.Rows, error)

+ func (qc *QueryChain) Count() (int64, error)

+ func (qc *QueryChain) First() (*sql.Row, error)

+ func (qc *QueryChain) Limit(limit int) *QueryChain

+ func (qc *QueryChain) Offset(offset int) *QueryChain

+ func (qc *QueryChain) OrderBy(orderBy string) *QueryChain

+ func (qc *QueryChain) Where(condition string, args ...interface{}) *QueryChain

+ type QueryConstructor interface

+ Build func(ctx context.Context) (string, []interface{}, error)

+ GetNativeBuilder func() interface{}

+ Limit func(count int) QueryConstructor

+ Offset func(count int) QueryConstructor

+ OrderBy func(field string, direction string) QueryConstructor

+ Select func(fields ...string) QueryConstructor

+ Where func(condition Condition) QueryConstructor

+ WhereAll func(conditions ...Condition) QueryConstructor

+ WhereAny func(conditions ...Condition) QueryConstructor

+ type QueryConstructorProvider interface

+ GetCapabilities func() *QueryBuilderCapabilities

+ NewQueryConstructor func(schema Schema) QueryConstructor

+ type QueryFallbackStrategy string

+ const QueryFallbackAlternativeSyntax

+ const QueryFallbackApplicationLayer

+ const QueryFallbackMultiQuery

+ const QueryFallbackNone

+ const QueryFallbackTemporaryTable

+ type QueryFeature struct

+ Fallback QueryFallbackStrategy

+ Name string

+ Notes string

+ SQLExamples map[string]string

+ Supported bool

+ type QueryFeatureCategory string

+ const QueryCategoryAdvancedQueries

+ const QueryCategoryAggregation

+ const QueryCategoryBasicOps

+ const QueryCategoryJSON

+ const QueryCategoryJoinOps

+ const QueryCategoryTextSearch

+ type QueryFeatures struct

+ AdapterTags []string

+ AlternativeSyntax map[string]string

+ FallbackStrategies map[string]QueryFallbackStrategy

+ FeatureNotes map[string]string

+ FeatureSupport map[string]FeatureSupport

+ OptimizationNotes map[string]string

+ RecursiveOptimizationHasNativeSyntax bool

+ RecursiveOptimizationIsOptimal bool

+ RecursiveOptimizationPriority int

+ RecursiveOptimizationSupported bool

+ SearchOptimizationIsOptimal bool

+ SearchOptimizationPriority int

+ SearchOptimizationSupported bool

+ SupportsArrayAggregate bool

+ SupportsBetween bool

+ SupportsCTE bool

+ SupportsCase bool

+ SupportsCaseWithElse bool

+ SupportsCastType bool

+ SupportsCoalesce bool

+ SupportsCorrelatedSubquery bool

+ SupportsCrossJoin bool

+ SupportsDistinct bool

+ SupportsExcept bool

+ SupportsFullOuterJoin bool

+ SupportsFullTextSearch bool

+ SupportsFuzzyMatch bool

+ SupportsGroupBy bool

+ SupportsHaving bool

+ SupportsIN bool

+ SupportsIfExists bool

+ SupportsInnerJoin bool

+ SupportsInsertIgnore bool

+ SupportsIntersect bool

+ SupportsJSONAgg bool

+ SupportsJSONOperators bool

+ SupportsJSONPath bool

+ SupportsJSONType bool

+ SupportsLeftJoin bool

+ SupportsLike bool

+ SupportsLimit bool

+ SupportsMaterializedView bool

+ SupportsNotIN bool

+ SupportsNulls bool

+ SupportsOffset bool

+ SupportsOrderBy bool

+ SupportsOrderByInAggregate bool

+ SupportsRecursiveCTE bool

+ SupportsRegexMatch bool

+ SupportsRightJoin bool

+ SupportsSelfJoin bool

+ SupportsStringAggregate bool

+ SupportsSubquery bool

+ SupportsUnion bool

+ SupportsUpsert bool

+ SupportsView bool

+ SupportsViewForPreload bool

+ SupportsWindowFunc bool

+ func GetQueryFeatures(dbType string) *QueryFeatures

+ func NewMongoQueryFeatures() *QueryFeatures

+ func NewMySQLQueryFeatures() *QueryFeatures

+ func NewPostgreSQLQueryFeatures() *QueryFeatures

+ func NewSQLServerQueryFeatures() *QueryFeatures

+ func NewSQLiteQueryFeatures() *QueryFeatures

+ func (qf *QueryFeatures) GetAlternativeSyntax(feature string) string

+ func (qf *QueryFeatures) GetFallbackStrategy(feature string) QueryFallbackStrategy

+ func (qf *QueryFeatures) GetFeatureNote(feature string) string

+ func (qf *QueryFeatures) GetFeatureSupport(feature string) FeatureSupport

+ func (qf *QueryFeatures) HasQueryFeature(feature string) bool

+ func (qf *QueryFeatures) SupportsFeatureWithVersion(feature, version string) bool

+ type RawSQLMigration struct

+ func NewRawSQLMigration(version, description string) *RawSQLMigration

+ func (m *RawSQLMigration) AddDownSQL(sql string) *RawSQLMigration

+ func (m *RawSQLMigration) AddUpSQL(sql string) *RawSQLMigration

+ func (m *RawSQLMigration) Down(ctx context.Context, repo *Repository) error

+ func (m *RawSQLMigration) ForAdapter(adapter string) *RawSQLMigration

+ func (m *RawSQLMigration) Up(ctx context.Context, repo *Repository) error

+ type RelationType string

+ const ManyToMany

+ const ManyToOne

+ const OneToMany

+ const OneToOne

+ type Relationship struct

+ ForeignKey *ForeignKeyDef

+ FromSchema Schema

+ JoinTable *JoinTableDef

+ Name string

+ ToSchema Schema

+ Type RelationType

+ type RelationshipManager interface

+ CreateRelationship func(ctx context.Context, rel *Relationship) error

+ DropRelationship func(ctx context.Context, fromTable, relName string) error

+ GetRelationshipSupport func() *RelationshipSupport

+ HasRelationship func(ctx context.Context, fromTable, relName string) (bool, error)

+ QueryWithRelation func(ctx context.Context, schema Schema, rel *Relationship, query string, ...) (interface{}, error)

+ type RelationshipStrategy string

+ const StrategyApplication

+ const StrategyForeignKey

+ const StrategyJoinTable

+ const StrategyNative

+ const StrategyNotSupported

+ type RelationshipSupport struct

+ ManyToMany bool

+ OneToMany bool

+ OneToOne bool

+ Strategy RelationshipStrategy

+ SupportsForeignKey bool

+ SupportsJoin bool

+ SupportsNested bool

+ type RelationshipValidator struct

+ func NewRelationshipValidator(support *RelationshipSupport) *RelationshipValidator

+ func (v *RelationshipValidator) CanJoin() bool

+ func (v *RelationshipValidator) GetSupportSummary() map[string]bool

+ func (v *RelationshipValidator) NeedsManyToManyEmulation(rel *Relationship) bool

+ func (v *RelationshipValidator) ValidateRelationship(rel *Relationship) error

+ type Repository struct

+ func InitDB(configPath string) (*Repository, error)

+ func InitDBFromAdapterRegistry(configPath, adapterName string) (*Repository, error)

+ func InitDBFromEnv() (*Repository, error)

+ func InitDBWithDefaults(adapterType string) (*Repository, error)

+ func NewRepository(config *Config) (*Repository, error)

+ func NewRepositoryFromAdapterConfig(name string) (*Repository, error)

+ func (r *Repository) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (r *Repository) Close() error

+ func (r *Repository) Connect(ctx context.Context) error

+ func (r *Repository) Exec(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

+ func (r *Repository) GetAdapter() Adapter

+ func (r *Repository) GetGormDB() *gorm.DB

+ func (r *Repository) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (r *Repository) Ping(ctx context.Context) error

+ func (r *Repository) Query(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

+ func (r *Repository) QueryRow(ctx context.Context, sql string, args ...interface{}) *sql.Row

+ func (r *Repository) QueryStruct(ctx context.Context, dest interface{}, sql string, args ...interface{}) error

+ func (r *Repository) QueryStructs(ctx context.Context, dest interface{}, sql string, args ...interface{}) error

+ func (r *Repository) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (r *Repository) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type RequiredValidator struct

+ func (v *RequiredValidator) Validate(value interface{}) error

+ type SQLDialect interface

+ GenerateLimitOffset func(limit *int, offset *int) string

+ GetPlaceholder func(index int) string

+ Name func() string

+ QuoteIdentifier func(name string) string

+ QuoteValue func(value interface{}) string

+ TranslateCondition func(condition Condition, argIndex *int) (string, []interface{}, error)

+ type SQLQueryConstructor struct

+ func NewSQLQueryConstructor(schema Schema, dialect SQLDialect) *SQLQueryConstructor

+ func (qb *SQLQueryConstructor) Build(ctx context.Context) (string, []interface{}, error)

+ func (qb *SQLQueryConstructor) GetNativeBuilder() interface{}

+ func (qb *SQLQueryConstructor) Limit(count int) QueryConstructor

+ func (qb *SQLQueryConstructor) Offset(count int) QueryConstructor

+ func (qb *SQLQueryConstructor) OrderBy(field string, direction string) QueryConstructor

+ func (qb *SQLQueryConstructor) Select(fields ...string) QueryConstructor

+ func (qb *SQLQueryConstructor) Where(condition Condition) QueryConstructor

+ func (qb *SQLQueryConstructor) WhereAll(conditions ...Condition) QueryConstructor

+ func (qb *SQLQueryConstructor) WhereAny(conditions ...Condition) QueryConstructor

+ type SQLServerAdapter struct

+ func (a *SQLServerAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *SQLServerAdapter) Close() error

+ func (a *SQLServerAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *SQLServerAdapter) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (a *SQLServerAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *SQLServerAdapter) GetGormDB() *gorm.DB

+ func (a *SQLServerAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *SQLServerAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *SQLServerAdapter) GetRawConn() interface{}

+ func (a *SQLServerAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *SQLServerAdapter) Ping(ctx context.Context) error

+ func (a *SQLServerAdapter) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (a *SQLServerAdapter) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (a *SQLServerAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *SQLServerAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type SQLServerDialect struct

+ func NewSQLServerDialect() *SQLServerDialect

+ func (d *SQLServerDialect) GenerateLimitOffset(limit *int, offset *int) string

+ func (d *SQLServerDialect) GetPlaceholder(index int) string

+ func (d *SQLServerDialect) Name() string

+ func (d *SQLServerDialect) QuoteIdentifier(name string) string

+ func (d *SQLServerDialect) QuoteValue(value interface{}) string

+ func (d *SQLServerDialect) TranslateCondition(condition Condition, argIndex *int) (string, []interface{}, error)

+ type SQLServerFactory struct

+ func (f *SQLServerFactory) Create(config *Config) (Adapter, error)

+ func (f *SQLServerFactory) Name() string

+ type SQLServerTx struct

+ func (t *SQLServerTx) Commit(ctx context.Context) error

+ func (t *SQLServerTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *SQLServerTx) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *SQLServerTx) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *SQLServerTx) Rollback(ctx context.Context) error

+ type SQLiteAdapter struct

+ func NewSQLiteAdapter(config *Config) (*SQLiteAdapter, error)

+ func (a *SQLiteAdapter) Begin(ctx context.Context, opts ...interface{}) (Tx, error)

+ func (a *SQLiteAdapter) Close() error

+ func (a *SQLiteAdapter) Connect(ctx context.Context, config *Config) error

+ func (a *SQLiteAdapter) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (a *SQLiteAdapter) GetDatabaseFeatures() *DatabaseFeatures

+ func (a *SQLiteAdapter) GetGormDB() *gorm.DB

+ func (a *SQLiteAdapter) GetQueryBuilderProvider() QueryConstructorProvider

+ func (a *SQLiteAdapter) GetQueryFeatures() *QueryFeatures

+ func (a *SQLiteAdapter) GetRawConn() interface{}

+ func (a *SQLiteAdapter) ListScheduledTasks(ctx context.Context) ([]*ScheduledTaskStatus, error)

+ func (a *SQLiteAdapter) Ping(ctx context.Context) error

+ func (a *SQLiteAdapter) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (a *SQLiteAdapter) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (a *SQLiteAdapter) RegisterCommonSQLiteFunctions() error

+ func (a *SQLiteAdapter) RegisterSQLiteAggregateFunction(fn *SQLiteAggregateFunction) error

+ func (a *SQLiteAdapter) RegisterSQLiteFunction(fn *SQLiteCustomFunction) error

+ func (a *SQLiteAdapter) RegisterScheduledTask(ctx context.Context, task *ScheduledTaskConfig) error

+ func (a *SQLiteAdapter) UnregisterScheduledTask(ctx context.Context, taskName string) error

+ type SQLiteAggregateFunction struct

+ Final func(ctx interface{}) (interface{}, error)

+ Name string

+ NumArgs int

+ Step func(ctx interface{}, args ...interface{}) (interface{}, error)

+ type SQLiteCustomFunction struct

+ Impl func(args ...interface{}) (interface{}, error)

+ Name string

+ NumArgs int

+ Pure bool

+ type SQLiteDialect struct

+ func NewSQLiteDialect() *SQLiteDialect

+ type SQLiteDynamicTableHook struct

+ func NewSQLiteDynamicTableHook(adapter *SQLiteAdapter) *SQLiteDynamicTableHook

+ func (h *SQLiteDynamicTableHook) CreateDynamicTable(ctx context.Context, configName string, params map[string]interface{}) (string, error)

+ func (h *SQLiteDynamicTableHook) GetDynamicTableConfig(ctx context.Context, configName string) (*DynamicTableConfig, error)

+ func (h *SQLiteDynamicTableHook) ListCreatedDynamicTables(ctx context.Context, configName string) ([]string, error)

+ func (h *SQLiteDynamicTableHook) ListDynamicTableConfigs(ctx context.Context) ([]*DynamicTableConfig, error)

+ func (h *SQLiteDynamicTableHook) RegisterDynamicTable(ctx context.Context, config *DynamicTableConfig) error

+ func (h *SQLiteDynamicTableHook) UnregisterDynamicTable(ctx context.Context, configName string) error

+ type SQLiteTx struct

+ func (t *SQLiteTx) Commit(ctx context.Context) error

+ func (t *SQLiteTx) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *SQLiteTx) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *SQLiteTx) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *SQLiteTx) Rollback(ctx context.Context) error

+ type ScheduledTaskConfig struct

+ Config map[string]interface{}

+ CronExpression string

+ Description string

+ Enabled bool

+ Name string

+ Type ScheduledTaskType

+ func (c *ScheduledTaskConfig) GetMonthlyTableConfig() map[string]interface{}

+ func (c *ScheduledTaskConfig) Validate() error

+ type ScheduledTaskEventListener interface

+ OnTaskExecutionCompleted func(ctx context.Context, taskName string, err error) error

+ OnTaskExecutionStarted func(ctx context.Context, taskName string) error

+ OnTaskRegistered func(ctx context.Context, config *ScheduledTaskConfig) error

+ OnTaskUnregistered func(ctx context.Context, taskName string) error

+ type ScheduledTaskExecutor interface

+ Execute func(ctx context.Context, taskName string, config *ScheduledTaskConfig) error

+ type ScheduledTaskStatus struct

+ CreatedAt int64

+ Info map[string]interface{}

+ LastExecutedAt int64

+ Name string

+ NextExecutedAt int64

+ Running bool

+ Type ScheduledTaskType

+ type ScheduledTaskType string

+ const TaskTypeMonthlyTableCreation

+ type Schema interface

+ Fields func() []*Field

+ GetField func(name string) *Field

+ PrimaryKeyField func() *Field

+ TableName func() string

+ type SchemaMigration struct

+ func NewSchemaMigration(version, description string) *SchemaMigration

+ func (m *SchemaMigration) CreateTable(schema Schema) *SchemaMigration

+ func (m *SchemaMigration) Down(ctx context.Context, repo *Repository) error

+ func (m *SchemaMigration) DropTable(schema Schema) *SchemaMigration

+ func (m *SchemaMigration) Up(ctx context.Context, repo *Repository) error

+ type SchemaRegistry struct

+ func NewSchemaRegistry() *SchemaRegistry

+ func (r *SchemaRegistry) Get(name string) Schema

+ func (r *SchemaRegistry) GetAllSchemaNames() []string

+ func (r *SchemaRegistry) Register(name string, schema Schema)

+ type SchemaRelationshipBuilder struct

+ func NewSchemaRelationshipBuilder(schema *BaseSchema) *SchemaRelationshipBuilder

+ func (b *SchemaRelationshipBuilder) BelongsTo(name string, toSchema Schema, foreignKey, primaryKey string) *SchemaRelationshipBuilder

+ func (b *SchemaRelationshipBuilder) GetRelationships() []*Relationship

+ func (b *SchemaRelationshipBuilder) HasAndBelongsToMany(name string, toSchema Schema, joinTableName string, fromForeignKey string, ...) *SchemaRelationshipBuilder

+ func (b *SchemaRelationshipBuilder) HasMany(name string, toSchema Schema, foreignKey, primaryKey string) *SchemaRelationshipBuilder

+ func (b *SchemaRelationshipBuilder) HasOne(name string, toSchema Schema, foreignKey, primaryKey string) *SchemaRelationshipBuilder

+ type SimpleCondition struct

+ Field string

+ Operator string

+ Value interface{}

+ func (c *SimpleCondition) Translate(translator ConditionTranslator) (string, []interface{}, error)

+ func (c *SimpleCondition) Type() string

+ type Transformer interface

+ Transform func(value interface{}) (interface{}, error)

+ type TrimTransformer struct

+ func (t *TrimTransformer) Transform(value interface{}) (interface{}, error)

+ type Tx interface

+ Commit func(ctx context.Context) error

+ Exec func(ctx context.Context, sql string, args ...interface{}) (sql.Result, error)

+ Query func(ctx context.Context, sql string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) *sql.Row

+ Rollback func(ctx context.Context) error

+ type TypeConversionError struct

+ From string

+ To string

+ func (e *TypeConversionError) Error() string

+ type UniqueValidator struct

+ Field string

+ Schema Schema

+ func (v *UniqueValidator) Validate(value interface{}) error

+ type ValidationError struct

+ Code string

+ Message string

+ func NewValidationError(code, message string) *ValidationError

+ func (e *ValidationError) Error() string

+ type Validator interface

+ Validate func(value interface{}) error

v0.4.3-patch.1

Feb 4, 2026

v0.4.2

Feb 3, 2026

v0.4.1

Feb 3, 2026

v0.4.0

Feb 3, 2026

v0.3.1

Feb 3, 2026

v0.2.1

Feb 2, 2026

v0.2.0

Feb 2, 2026

v0.2.0-fix

Feb 2, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL