database

package

Go to main page

Versions in this module

v0

v0.2.12

Jan 9, 2025

v0.2.11

Nov 25, 2024

Changes in this version

+ func VerifyAuthN(user, password string) error

v0.2.10

Oct 10, 2024

v0.2.9

Aug 4, 2024

v0.2.8

Aug 3, 2024

v0.2.7

Jul 11, 2024

Changes in this version

+ func UpdateRole(ctx context.Context, name string, role *RoleUpdate) error

+ func UpdateSchema(ctx context.Context, name string, schema *SchemaUpdate) error

type Column

+ Schema string

type ColumnType

+ Schema string

type Constraint

+ RelatedSchema *string

+ Schema string

+ type DatabaseUpdate struct

+ Name *string

+ Owner *string

type DbConn

+ func GetConnAndSchema(ctx context.Context) (*DbConn, string)

type DbEngine

+ func (dbe *DbEngine) UpdateDatabase(ctx context.Context, name string, update *DatabaseUpdate) error

type ForeignKey

+ RelatedSchema string

+ Schema string

type Function

+ Schema string

type QueryOptions

+ func GetQueryOptions(ctx context.Context) *QueryOptions

+ type RoleUpdate struct

+ CanBypassRLS *bool

+ CanCreateDatabases *bool

+ CanCreateRoles *bool

+ CanLogin *bool

+ IsSuperUser *bool

+ Name *string

+ NoInheritPrivileges *bool

type Schema

+ func GetSchema(ctx context.Context, name string) (*Schema, error)

+ type SchemaUpdate struct

+ Name *string

+ Owner *string

type Table

+ Schema string

type TableUpdate

+ Schema *string

type View

+ Schema string

v0.2.6

Apr 15, 2024

Changes in this version

+ func DeleteView(ctx context.Context, name string) error

+ type BinarySerializer struct

+ func (b *BinarySerializer) Serialize(rows pgx.Rows, scalar bool, single bool, info *SchemaInfo) ([]byte, int64, error)

type View

+ func CreateView(ctx context.Context, view *View) (*View, error)

+ func GetView(ctx context.Context, name string) (*View, error)

+ func GetViews(ctx context.Context) ([]View, error)

v0.2.5

Apr 1, 2024

Changes in this version

+ type CSVSerializer struct

+ func (csv *CSVSerializer) Serialize(rows pgx.Rows, scalar bool, single bool, info *SchemaInfo) ([]byte, int64, error)

+ type ContentTypeError struct

+ func (e ContentTypeError) Error() string

type Function

+ IsVariadic bool

+ func GetFunctions(ctx context.Context) ([]Function, error)

+ type JSONSerializer struct

+ func (j *JSONSerializer) Serialize(rows pgx.Rows, scalar bool, single bool, info *SchemaInfo) ([]byte, int64, error)

type QueryOptions

+ ParamsAsSingleObject bool

+ type TextBuilder struct

+ type TextSerializer interface

+ Serialize func(rows pgx.Rows, scalar bool, single bool, info *SchemaInfo) ([]byte, int64, error)

v0.2.4

Mar 19, 2024

Changes in this version

+ func GetDbRole(ctx context.Context) string

+ func GetDynStructures(ctx context.Context, query string) ([]any, error)

+ func QueryExec(ctx context.Context, query string, values ...any) error

+ func QueryStructure[T any](ctx context.Context, query string, values ...any) (*T, error)

+ func QueryStructures[T any](ctx context.Context, query string, values ...any) ([]T, error)

+ func SetResponseHeaders(ctx context.Context, w http.ResponseWriter, r *http.Request, count int64)

type DbEngine

+ func (dbe *DbEngine) GetMainDatabase(ctx context.Context) (*Database, error)

type QueryOptions

+ Count string

+ HasRange bool

+ RangeMax int64

+ RangeMin int64

+ type RangeError struct

+ func (e RangeError) Error() string

type Type

+ DomainSubType string

+ IsDomain bool

v0.2.3

Feb 29, 2024

Changes in this version

+ const DEFAULT_ANON

+ const SMOOTHDB

+ func CheckDatabase(dbConfig *Config) (bool, error)

+ func IsExist(err error) bool

+ func PrepareDatabase(adminURL string, dbConfig *Config) error

type DbEngine

+ func (dbe *DbEngine) CloneDatabase(ctx context.Context, name string, source string, force bool) (*DatabaseInfo, error)

+ func (dbe *DbEngine) GetOrCreateActiveDatabase(ctx context.Context, name string) (*Database, error)

+ type PostgresConfig struct

+ Database string

+ Host string

+ Password string

+ Port uint16

+ User string

+ func ParsePostgresURL(url string) (*PostgresConfig, error)

v0.2.2

Feb 13, 2024

v0.2.1

Jan 27, 2024

v0.2.0

Jan 18, 2024

Changes in this version

+ func CreateRecords(ctx context.Context, table string, records []Record, filters Filters) ([]byte, int64, error)

+ func Delete(ctx context.Context, table string, filters Filters) ([]byte, int64, error)

+ func DeleteFunction(ctx context.Context, name string) error

+ func DeleteRecords(ctx context.Context, table string, filters Filters) ([]byte, int64, error)

+ func ExecFunction(ctx context.Context, name string, record Record, filters Filters) ([]byte, int64, error)

+ func Execute(ctx context.Context, function string, record Record, filters Filters) ([]byte, int64, error)

+ func GetMaps(ctx context.Context, query string) ([]map[string]any, error)

+ func GetRecords(ctx context.Context, table string, filters Filters) ([]byte, error)

+ func GetStructures(ctx context.Context, query string) ([]any, error)

+ func Insert(ctx context.Context, table string, records []Record, filters Filters) ([]byte, int64, error)

+ func Select(ctx context.Context, table string, filters Filters) ([]byte, error)

+ func Update(ctx context.Context, table string, record Record, filters Filters) ([]byte, int64, error)

+ func UpdateRecords(ctx context.Context, table string, record Record, filters Filters) ([]byte, int64, error)

type Config

+ TransactionMode string

+ type CustomRows struct

+ CurrentRow int

+ FieldDescriptions_ []pgconn.FieldDescription

+ RawValues_ [][][]byte

+ func CopyRows(rows pgx.Rows) (*CustomRows, error)

+ func (cr *CustomRows) Close()

+ func (cr *CustomRows) CommandTag() pgconn.CommandTag

+ func (cr *CustomRows) Conn() *pgx.Conn

+ func (cr *CustomRows) Err() error

+ func (cr *CustomRows) FieldDescriptions() []pgconn.FieldDescription

+ func (cr *CustomRows) Next() bool

+ func (cr *CustomRows) RawValues() [][]byte

+ func (cr *CustomRows) Scan(dest ...any) error

+ func (cr *CustomRows) Values() ([]any, error)

type Function

+ func CreateFunction(ctx context.Context, function *Function) (*Function, error)

v0.1.2

Jan 7, 2024

Changes in this version

+ func DeleteColumn(ctx context.Context, table string, name string, cascade bool) error

+ func DeleteConstraint(ctx context.Context, table string, name string) error

+ func DeleteTable(ctx context.Context, name string, ifExists bool) error

type Column

+ func CreateColumn(ctx context.Context, column *Column) (*Column, error)

+ func GetColumn(ctx context.Context, ftablename string, name string) (*Column, error)

+ func GetColumns(ctx context.Context, ftablename string) ([]Column, error)

+ func UpdateColumn(ctx context.Context, column *ColumnUpdate) (*Column, error)

type ColumnType

+ func GetColumnTypes(ctx context.Context) ([]ColumnType, error)

type Constraint

+ func CreateConstraint(ctx context.Context, constraint *Constraint) (*Constraint, error)

+ func GetConstraints(ctx context.Context, tablename string) ([]Constraint, error)

type Database

+ func (db *Database) GetMaps(ctx context.Context, query string) ([]map[string]any, error)

type Table

+ func CreateTable(ctx context.Context, table *Table) (*Table, error)

+ func GetTable(ctx context.Context, name string) (*Table, error)

+ func GetTables(ctx context.Context) ([]Table, error)

+ func UpdateTable(ctx context.Context, table *TableUpdate) (*Table, error)

type User

+ CanCreateDatabases bool

+ CanCreateRoles bool

v0.1.1

Dec 10, 2023

v0.1.0

Dec 8, 2023

Changes in this version

+ func CleanStressTest()

+ func ContextWithDbConn(parent context.Context, db *Database, conn *DbConn) context.Context

+ func DeletePolicy(ctx context.Context, table string, name string) error

+ func DeletePrivilege(ctx context.Context, privilege *Privilege) error

+ func DeleteRole(ctx context.Context, name string) error

+ func DeleteSchema(ctx context.Context, name string, cascade bool) error

+ func DeleteUser(ctx context.Context, name string) error

+ func FillContext(ctx context.Context, r *http.Request, db *Database, conn *DbConn, role string) context.Context

+ func HasTX(c *DbPoolConn) bool

+ func PrepareConnection(ctx context.Context, conn *DbPoolConn, role string, claims string, ...) error

+ func PrepareStressTest(conn *pgxpool.Conn)

+ func ReleaseConn(ctx context.Context, conn *DbPoolConn) error

+ func ReleaseConnection(ctx context.Context, conn *DbPoolConn, err bool, resetRole bool) error

+ func SetQueryBuilder(ctx context.Context, qb QueryBuilder)

+ func SetRequestParser(ctx context.Context, rp RequestParser)

+ func StressTest()

+ type Argument struct

+ Mode byte

+ Name string

+ Type string

+ type BuildError struct

+ func (e *BuildError) Error() string

+ type BuildStack struct

+ type Column struct

+ Constraints []string

+ Default *string

+ Name string

+ NotNull bool

+ Table string

+ Type string

+ type ColumnType struct

+ DataType string

+ IsArray bool

+ IsComposite bool

+ Name string

+ Table string

+ Type string

+ type ColumnUpdate struct

+ Default *string

+ Name string

+ NewName *string

+ NotNull *bool

+ Table string

+ Type *string

+ type CommonBuilder struct

+ func (CommonBuilder) BuildDelete(table string, parts *QueryParts, options QueryOptions, info *SchemaInfo) (delete string, valueList []any, err error)

+ func (CommonBuilder) BuildExecute(name string, record Record, parts *QueryParts, options QueryOptions, ...) (exec string, valueList []any, err error)

+ func (CommonBuilder) BuildInsert(table string, records []Record, parts *QueryParts, options QueryOptions, ...) (insert string, valueList []any, err error)

+ func (CommonBuilder) BuildUpdate(table string, record Record, parts *QueryParts, options QueryOptions, ...) (update string, valueList []any, err error)

+ type Config struct

+ AllowedDatabases []string

+ AnonRole string

+ AuthRole string

+ MaxPoolConnections int32

+ MinPoolConnections int32

+ SchemaSearchPath []string

+ TransactionEnd string

+ URL string

+ func DefaultConfig() *Config

+ type Constraint struct

+ Columns []string

+ Definition string

+ Name string

+ RelatedColumns []string

+ RelatedTable *string

+ Table string

+ Type byte

+ type Database struct

+ func GetDb(ctx context.Context) *Database

+ func (db *Database) AcquireConnection(ctx context.Context) (*pgxpool.Conn, error)

+ func (db *Database) Activate(ctx context.Context) error

+ func (db *Database) Close()

+ func (db *Database) CreateColumn(ctx context.Context, column *Column) (*Column, error)

+ func (db *Database) CreateConstraint(ctx context.Context, constraint *Constraint) (*Constraint, error)

+ func (db *Database) CreateFunction(ctx context.Context, function *Function) (*Function, error)

+ func (db *Database) CreateRecords(ctx context.Context, table string, records []Record, filters Filters) ([]byte, int64, error)

+ func (db *Database) CreateTable(ctx context.Context, table *Table) (*Table, error)

+ func (db *Database) CreateView(ctx context.Context, view *View) (*View, error)

+ func (db *Database) DeleteColumn(ctx context.Context, table string, name string, cascade bool) error

+ func (db *Database) DeleteConstraint(ctx context.Context, table string, name string) error

+ func (db *Database) DeleteFunction(ctx context.Context, name string) error

+ func (db *Database) DeleteRecords(ctx context.Context, table string, filters Filters) ([]byte, int64, error)

+ func (db *Database) DeleteTable(ctx context.Context, name string) error

+ func (db *Database) DeleteView(ctx context.Context, name string) error

+ func (db *Database) ExecFunction(ctx context.Context, name string, record Record, filters Filters) ([]byte, int64, error)

+ func (db *Database) GetColumn(ctx context.Context, ftablename string, name string) (*Column, error)

+ func (db *Database) GetColumnTypes(ctx context.Context) ([]ColumnType, error)

+ func (db *Database) GetColumns(ctx context.Context, ftablename string) ([]Column, error)

+ func (db *Database) GetConstraints(ctx context.Context, tablename string) ([]Constraint, error)

+ func (db *Database) GetFunctions(ctx context.Context) ([]Function, error)

+ func (db *Database) GetRecords(ctx context.Context, table string, filters Filters) ([]byte, error)

+ func (db *Database) GetStructures(ctx context.Context, query string) ([]any, error)

+ func (db *Database) GetTable(ctx context.Context, name string) (*Table, error)

+ func (db *Database) GetTables(ctx context.Context) ([]Table, error)

+ func (db *Database) GetView(ctx context.Context, name string) (*View, error)

+ func (db *Database) GetViews(ctx context.Context) ([]View, error)

+ func (db *Database) UpdateColumn(ctx context.Context, column *ColumnUpdate) (*Column, error)

+ func (db *Database) UpdateRecords(ctx context.Context, table string, record Record, filters Filters) ([]byte, int64, error)

+ func (db *Database) UpdateTable(ctx context.Context, table *TableUpdate) (*Table, error)

+ type DatabaseInfo struct

+ Name string

+ Owner string

+ type DatabaseJSONSerializer struct

+ func (DatabaseJSONSerializer) Serialize(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ func (DatabaseJSONSerializer) SerializeSingle(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ type DbConn = pgx.Conn

+ func GetConn(ctx context.Context) *DbConn

+ type DbEngine struct

+ var DBE *DbEngine

+ func InitDbEngine(dbConfig *Config, logger *logging.Logger) (*DbEngine, error)

+ func (dbe *DbEngine) AcquireConnection(ctx context.Context) (*pgxpool.Conn, error)

+ func (dbe *DbEngine) Close()

+ func (dbe *DbEngine) CreateActiveDatabase(ctx context.Context, name string) (*Database, error)

+ func (dbe *DbEngine) CreateDatabase(ctx context.Context, name string) (*DatabaseInfo, error)

+ func (dbe *DbEngine) DeleteDatabase(ctx context.Context, name string) error

+ func (dbe *DbEngine) GetActiveDatabase(ctx context.Context, name string) (*Database, error)

+ func (dbe *DbEngine) GetDatabase(ctx context.Context, name string) (*DatabaseInfo, error)

+ func (dbe *DbEngine) GetDatabases(ctx context.Context) ([]DatabaseInfo, error)

+ func (dbe *DbEngine) IsDatabaseAllowed(name string) bool

+ type DbLogger struct

+ func NewDbLogger(logger *zerolog.Logger) *DbLogger

+ func (pl *DbLogger) Log(ctx context.Context, level tracelog.LogLevel, msg string, ...)

+ type DbPoolConn = pgxpool.Conn

+ func AcquireConnection(ctx context.Context, db *Database) (conn *DbPoolConn, err error)

+ func ContextWithDb(parent context.Context, db *Database, role string) (context.Context, *DbPoolConn, error)

+ type DirectJSONSerializer struct

+ func (d *DirectJSONSerializer) Serialize(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ func (d *DirectJSONSerializer) SerializeSingle(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ type DirectQueryBuilder struct

+ func (DirectQueryBuilder) BuildSelect(table string, parts *QueryParts, options QueryOptions, info *SchemaInfo) (string, []any, error)

+ type Field struct

+ type Filters = url.Values

+ type ForeignKey struct

+ Columns []string

+ Name string

+ RelatedColumns []string

+ RelatedTable string

+ Table string

+ type Function struct

+ Arguments []Argument

+ Definition string

+ HasOut bool

+ HasUnnamed bool

+ Language string

+ Name string

+ ReturnIsSet bool

+ ReturnTypeId uint32

+ Returns string

+ type Join struct

+ type OrderField struct

+ type ParseError struct

+ func (e *ParseError) Error() string

+ type Policy struct

+ Check *string

+ Command string

+ Name string

+ Retrictive bool

+ Roles []string

+ Table string

+ Using *string

+ func CreatePolicy(ctx context.Context, policy *Policy) (*Policy, error)

+ func GetPolicies(ctx context.Context, ftablename string) ([]Policy, error)

+ type PostgRestParser struct

+ type Privilege struct

+ ACL string

+ Columns []string

+ Grantee string

+ Grantor string

+ TargetName string

+ TargetSchema string

+ TargetType string

+ Types []string

+ func CreatePrivilege(ctx context.Context, privilege *Privilege) (*Privilege, error)

+ func GetDatabasePrivileges(ctx context.Context, dbname string) ([]Privilege, error)

+ func GetPrivileges(ctx context.Context, targetType string, targetName string) ([]Privilege, error)

+ type QueryBuilder interface

+ BuildDelete func(table string, parts *QueryParts, options QueryOptions, info *SchemaInfo) (string, []any, error)

+ BuildExecute func(table string, record Record, parts *QueryParts, options QueryOptions, ...) (string, []any, error)

+ BuildInsert func(table string, records []Record, parts *QueryParts, options QueryOptions, ...) (string, []any, error)

+ BuildSelect func(table string, parts *QueryParts, options QueryOptions, info *SchemaInfo) (string, []any, error)

+ BuildUpdate func(table string, record Record, parts *QueryParts, options QueryOptions, ...) (string, []any, error)

+ type QueryExecutor struct

+ func (QueryExecutor) Delete(ctx context.Context, table string, filters Filters) ([]byte, int64, error)

+ func (QueryExecutor) Execute(ctx context.Context, function string, record Record, filters Filters) ([]byte, int64, error)

+ func (QueryExecutor) Insert(ctx context.Context, table string, records []Record, filters Filters) ([]byte, int64, error)

+ func (QueryExecutor) Select(ctx context.Context, table string, filters Filters) ([]byte, error)

+ func (QueryExecutor) Update(ctx context.Context, table string, record Record, filters Filters) ([]byte, int64, error)

+ type QueryOptions struct

+ ContentType string

+ IgnoreDuplicates bool

+ MergeDuplicates bool

+ ReturnRepresentation bool

+ Schema string

+ Singular bool

+ TxCommit bool

+ TxRollback bool

+ type QueryParts struct

+ type QueryWithJSON struct

+ func (QueryWithJSON) BuildSelect(table string, parts *QueryParts, options QueryOptions, info *SchemaInfo) (string, []any, error)

+ type Record = map[string]any

+ type ReflectSerializer struct

+ func (ReflectSerializer) Serialize(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ type RelType int

+ const M2M

+ const M2O

+ const O2M

+ const O2O

+ type Relationship struct

+ Columns []string

+ JColumns []string

+ JRelatedColumns []string

+ JunctionTable string

+ RelatedColumns []string

+ RelatedTable string

+ Table string

+ Type RelType

+ type Request = http.Request

+ type RequestParser interface

+ type ResultSerializer interface

+ Serialize func(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ SerializeSingle func(ctx context.Context, rows pgx.Rows, scalar bool, info *SchemaInfo) ([]byte, error)

+ type Role struct

+ CanBypassRLS bool

+ CanCreateDatabases bool

+ CanCreateRoles bool

+ CanLogin bool

+ IsSuperUser bool

+ MemberOf []string

+ Name string

+ NoInheritPrivileges bool

+ func CreateRole(ctx context.Context, role *Role) (*Role, error)

+ func GetRole(ctx context.Context, name string) (*Role, error)

+ func GetRoles(ctx context.Context) ([]Role, error)

+ type Schema struct

+ Name string

+ Owner string

+ func CreateSchema(ctx context.Context, name string) (*Schema, error)

+ func GetSchemas(ctx context.Context) ([]Schema, error)

+ type SchemaInfo struct

+ func NewSchemaInfo(ctx context.Context, db *Database) (*SchemaInfo, error)

+ func (si *SchemaInfo) FindRelationshipByCol(table, col string) *Relationship

+ func (si *SchemaInfo) GetColumnType(table string, column string) *ColumnType

+ func (si *SchemaInfo) GetForeignKeys(table string) []ForeignKey

+ func (si *SchemaInfo) GetFunction(name string) *Function

+ func (si *SchemaInfo) GetPrimaryKey(table string) *Constraint

+ func (si *SchemaInfo) GetRelationships(table string) []Relationship

+ func (si *SchemaInfo) GetTable(table string) *Table

+ func (si *SchemaInfo) GetTypeById(id uint32) *Type

+ type SelectField struct

+ type SelectRelation struct

+ type SerializeError struct

+ func (e *SerializeError) Error() string

+ type SmoothContext struct

+ Conn *DbConn

+ Db *Database

+ QueryBuilder QueryBuilder

+ QueryOptions QueryOptions

+ RequestParser RequestParser

+ Role string

+ func GetSmoothContext(ctx context.Context) *SmoothContext

+ type Table struct

+ Columns []Column

+ Constraints []string

+ HasIndexes bool

+ HasTriggers bool

+ IfNotExists bool

+ Inherits string

+ IsPartition bool

+ Name string

+ Owner string

+ RowSecurity bool

+ type TableUpdate struct

+ Name string

+ NewName *string

+ NewSchema *string

+ Owner *string

+ RowSecurity *bool

+ type Type struct

+ ArraySubType uint32

+ Id uint32

+ IsArray bool

+ IsComposite bool

+ IsEnum bool

+ IsRange bool

+ IsTable bool

+ Name string

+ RangeSubType *uint32

+ Schema string

+ SubTypeIds []uint32

+ SubTypeNames []string

+ func GetTypes(ctx context.Context) ([]Type, error)

+ type User struct

+ MemberOf []string

+ Name string

+ func CreateUser(ctx context.Context, role *User) (*User, error)

+ func GetUser(ctx context.Context, name string) (*User, error)

+ func GetUsers(ctx context.Context) ([]User, error)

+ type View struct

+ Definition string

+ Materialized bool

+ Name string

+ Owner string

+ type WhereConditionNode struct

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