sqlite

Documentation

Index

• Constants
• func NewSqliteEntityStorage[T any, K storage.Key](getConnection func() *sqlx.DB, schema ITableSchema, ownerValue interface{}) (sto storage.IEntityStorage[T, K], err error)
• func NewSqliteLinkStorage[T any, KS storage.Key, KO storage.Key](getConnection func() *sqlx.DB, schema ITableSchema, ownerValue interface{}) (sto storage.ILinkStorage[T, KS, KO], err error)
• func NewSqliteRecordStorage[T any](getConnection func() *sqlx.DB, schema ITableSchema, ownerValue interface{}) (rto storage.IRecordStorage[T], err error)
• func VerifyDatabase(connection *sqlx.DB, tables []ITableSchema, applyChanges bool) (result []string, err error)
• type IColumnSchema
• type ISqliteStorage
• type ITableSchema
  • func LoadTableSchema(entityType reflect.Type, primaryKey []string, indexes map[string][]string, ...) (schema ITableSchema, err error)
• type SqlDataType
  • func (sdt SqlDataType) ToSqlType() string

Constants

const (
	SqlDataType_Integer = iota + 1
	SqlDataType_Numeric
	SqlDataType_String
	SqlDataType_Blob
)

Functions

func NewSqliteEntityStorage

func NewSqliteEntityStorage[T any, K storage.Key](
	getConnection func() *sqlx.DB, schema ITableSchema, ownerValue interface{}) (sto storage.IEntityStorage[T, K], err error)

func NewSqliteLinkStorage

func NewSqliteLinkStorage[T any, KS storage.Key, KO storage.Key](
	getConnection func() *sqlx.DB, schema ITableSchema,
	ownerValue interface{}) (sto storage.ILinkStorage[T, KS, KO], err error)

func NewSqliteRecordStorage

func NewSqliteRecordStorage[T any](
	getConnection func() *sqlx.DB, schema ITableSchema, ownerValue interface{}) (rto storage.IRecordStorage[T], err error)

func VerifyDatabase

func VerifyDatabase(connection *sqlx.DB, tables []ITableSchema, applyChanges bool) (result []string, err error)

Types

type IColumnSchema

type IColumnSchema interface {
	ColumnName() string
	ColumnSqlType() SqlDataType
}

type ISqliteStorage

type ISqliteStorage[T any] interface {
	SelectAll(func(T) bool) error
	SelectFilter([]string, [][]interface{}, func(T) bool) error
	Put([]T) error
	DeleteAll() error
	DeleteFilter([]string, [][]interface{}) error
}

type ITableSchema

type ITableSchema interface {
	TableName() string
	SetTableName(string)
	OwnerColumn() IColumnSchema
	Columns() []IColumnSchema
	PrimaryKey() []string
	Indexes() map[string][]string
	NewEntity() interface{}
	GetColumnByName(string) IColumnSchema
}

func LoadTableSchema

func LoadTableSchema(entityType reflect.Type, primaryKey []string, indexes map[string][]string,
	ownerColumn string, ownerType SqlDataType) (schema ITableSchema, err error)

type SqlDataType

type SqlDataType uint32

func (SqlDataType) ToSqlType

func (sdt SqlDataType) ToSqlType() string