database

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 20, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildInsertQuery 

func BuildInsertQuery(table string, columns []string, returning bool) string

BuildInsertQuery builds an INSERT query compatible with the current database

func BuildUpdateQuery 

func BuildUpdateQuery(table string, setColumns []string, whereClause string) string

BuildUpdateQuery builds an UPDATE query compatible with the current database

func CloseTestDB 

func CloseTestDB()

CloseTestDB is a no-op to avoid interfering with the global service-managed database connection. Left for API compatibility.

func ConvertPlaceholders 

func ConvertPlaceholders(query string) string

ConvertPlaceholders converts PostgreSQL placeholders ($1, $2) to MySQL placeholders (?) This allows us to write queries in PostgreSQL format and auto-convert for MySQL

func ConvertQuery 

func ConvertQuery(query string) string

ConvertQuery adapts a query for the current database This extends the existing ConvertPlaceholders functionality

func ConvertReturning 

func ConvertReturning(query string) (string, bool)

ConvertReturning handles RETURNING clause differences PostgreSQL: INSERT ... RETURNING * MySQL: Use LastInsertId() after insert

func GetAbstractDB 

func GetAbstractDB() (*sql.DB, error)

GetAbstractDB returns the global database instance (for backward compatibility)

func GetDB 

func GetDB() (*sql.DB, error)

GetDB returns the database connection singleton from the service registry. Service registry is the single source of truth for database connections.

func GetDBDriver 

func GetDBDriver() string

GetDBDriver returns the current database driver

func InitDB 

func InitDB() error

InitDB is kept for backward-compatibility with older tests; delegates to InitTestDB.

func InitTestDB 

func InitTestDB() error

InitTestDB initializes a database connection for tests using the project service adapter. It is safe to call multiple times. It does not create schema by default; individual tests should create required tables with CREATE TABLE IF NOT EXISTS as needed.

func InitializeDefault 

func InitializeDefault() error

InitializeDefault initializes the database with default configuration from environment

func IsMySQL 

func IsMySQL() bool

IsMySQL returns true if using MySQL/MariaDB

func IsPostgreSQL 

func IsPostgreSQL() bool

IsPostgreSQL returns true if using PostgreSQL

func QualifiedTicketTypeColumn 

func QualifiedTicketTypeColumn(alias string) string

QualifiedTicketTypeColumn returns the column name prefixed with the provided alias.

func QuoteIdentifier 

func QuoteIdentifier(name string) string

QuoteIdentifier quotes table/column names based on database

func RegisterDriver 

func RegisterDriver(name string, factory func() DatabaseDriver)

RegisterDriver registers a database driver

func RegisterDumpDriver 

func RegisterDumpDriver(name string, factory func() DumpDriver)

RegisterDumpDriver registers a dump file driver

func ResetAdapterForTest 

func ResetAdapterForTest()

ResetAdapterForTest clears the cached adapter so tests can rebuild state.

func ResetDB 

func ResetDB()

ResetDB clears the test-injected DB.

func SetAdapter 

func SetAdapter(adapter DBAdapter)

SetAdapter overrides the global adapter, primarily for tests.

func SetDB 

func SetDB(db *sql.DB)

SetDB allows tests to inject a mock *sql.DB for functions that call GetDB. Use ResetDB to restore the previous value.

func TicketTypeColumn 

func TicketTypeColumn() string

TicketTypeColumn returns the ticket type column name for the active driver.

Types

type ColumnDef 

type ColumnDef struct {
	Type     string      `yaml:"type"`     // varchar(200), int, serial, etc.
	Required bool        `yaml:"required"` // NOT NULL
	Unique   bool        `yaml:"unique"`
	Default  interface{} `yaml:"default"`
	Index    bool        `yaml:"index"`
}

ColumnDef represents a column definition

type ColumnDefinition 

type ColumnDefinition struct {
	Name          string
	DataType      string
	Size          *int
	Precision     *int
	Scale         *int
	NotNull       bool
	PrimaryKey    bool
	AutoIncrement bool
	DefaultValue  *string
}

ColumnDefinition defines a table column

type ColumnInfo 

type ColumnInfo struct {
	Name            string
	DataType        string
	IsNullable      bool
	DefaultValue    *string
	MaxLength       *int
	IsPrimaryKey    bool
	IsAutoIncrement bool
}

ColumnInfo represents database column information

type ConstraintDefinition 

type ConstraintDefinition struct {
	Name             string
	Type             string // PRIMARY_KEY, FOREIGN_KEY, UNIQUE, CHECK
	Columns          []string
	ReferenceTable   *string
	ReferenceColumns []string
	OnDelete         *string // CASCADE, SET NULL, RESTRICT
	OnUpdate         *string // CASCADE, SET NULL, RESTRICT
}

ConstraintDefinition defines a table constraint

type DBAdapter 

type DBAdapter interface {
	// InsertWithReturning handles INSERT ... RETURNING for different databases
	InsertWithReturning(db *sql.DB, query string, args ...interface{}) (int64, error)

	// InsertWithReturningTx handles INSERT ... RETURNING within a transaction
	InsertWithReturningTx(tx *sql.Tx, query string, args ...interface{}) (int64, error)

	// CaseInsensitiveLike returns the appropriate case-insensitive LIKE operator
	CaseInsensitiveLike(column, pattern string) string

	// TypeCast handles type casting for different databases
	TypeCast(value, targetType string) string
}

DBAdapter provides database-specific query adaptations

func GetAdapter 

func GetAdapter() DBAdapter

GetAdapter returns the appropriate database adapter based on configuration

type DatabaseConfig 

type DatabaseConfig struct {
	Type     DatabaseType `json:"type" yaml:"type"`
	Host     string       `json:"host" yaml:"host"`
	Port     string       `json:"port" yaml:"port"`
	Database string       `json:"database" yaml:"database"`
	Username string       `json:"username" yaml:"username"`
	Password string       `json:"password" yaml:"password"`
	SSLMode  string       `json:"ssl_mode" yaml:"ssl_mode"`

	// Connection pool settings
	MaxOpenConns    int           `json:"max_open_conns" yaml:"max_open_conns"`
	MaxIdleConns    int           `json:"max_idle_conns" yaml:"max_idle_conns"`
	ConnMaxLifetime time.Duration `json:"conn_max_lifetime" yaml:"conn_max_lifetime"`
	ConnMaxIdleTime time.Duration `json:"conn_max_idle_time" yaml:"conn_max_idle_time"`

	// Database-specific options
	Options map[string]string `json:"options,omitempty" yaml:"options,omitempty"`
}

DatabaseConfig holds database connection configuration

func LoadConfigFromEnv 

func LoadConfigFromEnv() DatabaseConfig

LoadConfigFromEnv loads database configuration from environment variables

type DatabaseDriver 

type DatabaseDriver interface {
	// Connection management
	Connect(ctx context.Context, dsn string) error
	Close() error
	Ping(ctx context.Context) error

	// Schema operations
	CreateTable(schema TableSchema) (Query, error)
	DropTable(tableName string) (Query, error)
	TableExists(tableName string) (bool, error)

	// CRUD operations
	Insert(table string, data map[string]interface{}) (Query, error)
	Update(table string, data map[string]interface{}, where string, whereArgs ...interface{}) (Query, error)
	Delete(table string, where string, whereArgs ...interface{}) (Query, error)
	Select(table string, columns []string, where string, whereArgs ...interface{}) (Query, error)

	// Type mapping
	MapType(schemaType string) string // e.g., "serial" -> "AUTO_INCREMENT" or "SERIAL"

	// Feature detection
	SupportsReturning() bool
	SupportsLastInsertId() bool
	SupportsArrays() bool

	// Transaction support
	BeginTx(ctx context.Context) (Transaction, error)

	// Raw execution (for complex queries)
	Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row
}

DatabaseDriver interface for database abstraction

func GetDriver 

func GetDriver(name string) (DatabaseDriver, error)

GetDriver returns a database driver by name

type DatabaseFactory 

type DatabaseFactory struct{}

DatabaseFactory implements IDatabaseFactory

func (*DatabaseFactory) Create 

func (f *DatabaseFactory) Create(config DatabaseConfig) (IDatabase, error)

Create creates a database instance based on the configuration

func (*DatabaseFactory) GetSupportedTypes 

func (f *DatabaseFactory) GetSupportedTypes() []DatabaseType

GetSupportedTypes returns the list of supported database types

func (*DatabaseFactory) ValidateConfig 

func (f *DatabaseFactory) ValidateConfig(config DatabaseConfig) error

ValidateConfig validates the database configuration

type DatabaseFeatures 

type DatabaseFeatures struct {
	SupportsReturning       bool
	SupportsUpsert          bool
	SupportsJSONColumn      bool
	SupportsArrayColumn     bool
	SupportsWindowFunctions bool
	SupportsCTE             bool // Common Table Expressions
	MaxIdentifierLength     int
	MaxIndexNameLength      int
}

DatabaseFeatures represents database-specific feature support

func GetDatabaseFeatures 

func GetDatabaseFeatures(dbType DatabaseType) DatabaseFeatures

GetDatabaseFeatures returns the features supported by a database type

type DatabaseType 

type DatabaseType string

DatabaseType represents the supported database backends 

const (
	PostgreSQL DatabaseType = "postgresql"
	MySQL      DatabaseType = "mysql"
	Oracle     DatabaseType = "oracle"
	SQLServer  DatabaseType = "sqlserver"
)

type DriverRegistry 

type DriverRegistry struct {
	// contains filtered or unexported fields
}

DriverRegistry for managing available drivers

type DumpDriver 

type DumpDriver interface {
	// Parse and iterate through a dump file
	Open(filename string) error
	Close() error

	// Read next statement from dump
	NextStatement() (string, error)

	// Get table schemas from dump
	GetSchemas() ([]TableSchema, error)

	// Stream data for a specific table
	StreamTable(tableName string, callback func(row map[string]interface{}) error) error

	// Write operations (for export)
	WriteSchema(schema TableSchema) error
	WriteData(table string, rows []map[string]interface{}) error
}

DumpDriver interface for SQL dump file handling

func GetDumpDriver 

func GetDumpDriver(name string) (DumpDriver, error)

GetDumpDriver returns a dump driver by name

type IDatabase 

type IDatabase interface {
	// Connection management
	Connect() error
	Close() error
	Ping() error
	GetType() DatabaseType
	GetConfig() DatabaseConfig

	// Query operations
	Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row
	Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

	// Transaction support
	Begin(ctx context.Context) (ITransaction, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (ITransaction, error)

	// Schema operations
	TableExists(ctx context.Context, tableName string) (bool, error)
	GetTableColumns(ctx context.Context, tableName string) ([]ColumnInfo, error)
	CreateTable(ctx context.Context, definition *TableDefinition) error
	DropTable(ctx context.Context, tableName string) error

	// Index operations
	CreateIndex(ctx context.Context, tableName, indexName string, columns []string, unique bool) error
	DropIndex(ctx context.Context, tableName, indexName string) error

	// Utility methods
	Quote(identifier string) string
	QuoteValue(value interface{}) string
	BuildInsert(tableName string, data map[string]interface{}) (string, []interface{})
	BuildUpdate(tableName string, data map[string]interface{}, where string, whereArgs []interface{}) (string, []interface{})
	BuildSelect(tableName string, columns []string, where string, orderBy string, limit int) string

	// Database-specific SQL generation
	GetLimitClause(limit, offset int) string
	GetDateFunction() string
	GetConcatFunction(fields []string) string
	SupportsReturning() bool

	// Health and monitoring
	Stats() sql.DBStats
	IsHealthy() bool
}

IDatabase defines the database abstraction interface (inspired by OTRS Kernel::System::DB)

func GetDatabase 

func GetDatabase() IDatabase

GetDatabase returns the database abstraction instance

type IDatabaseFactory 

type IDatabaseFactory interface {
	Create(config DatabaseConfig) (IDatabase, error)
	GetSupportedTypes() []DatabaseType
	ValidateConfig(config DatabaseConfig) error
}

IDatabaseFactory creates database instances

func NewDatabaseFactory 

func NewDatabaseFactory() IDatabaseFactory

NewDatabaseFactory creates a new database factory instance

type ITransaction 

type ITransaction interface {
	Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row
	Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	Commit() error
	Rollback() error
}

ITransaction defines the transaction interface

type IndexDefinition 

type IndexDefinition struct {
	Name    string
	Columns []string
	Unique  bool
	Type    string // btree, hash, gin, gist for PostgreSQL
}

IndexDefinition defines a table index

type Manager 

type Manager struct {
	// contains filtered or unexported fields
}

Manager provides a singleton database instance using the abstraction layer

func NewManager 

func NewManager() *Manager

NewManager creates a new database manager

func (*Manager) Initialize 

func (m *Manager) Initialize(config DatabaseConfig) error

Initialize sets up the database connection with the given configuration

type MySQLAdapter 

type MySQLAdapter struct{}

MySQLAdapter implements DBAdapter for MySQL/MariaDB

func (*MySQLAdapter) CaseInsensitiveLike 

func (m *MySQLAdapter) CaseInsensitiveLike(column, pattern string) string

func (*MySQLAdapter) InsertWithReturning 

func (m *MySQLAdapter) InsertWithReturning(db *sql.DB, query string, args ...interface{}) (int64, error)

func (*MySQLAdapter) InsertWithReturningTx 

func (m *MySQLAdapter) InsertWithReturningTx(tx *sql.Tx, query string, args ...interface{}) (int64, error)

func (*MySQLAdapter) TypeCast 

func (m *MySQLAdapter) TypeCast(value, targetType string) string

type MySQLDatabase 

type MySQLDatabase struct {
	// contains filtered or unexported fields
}

MySQLDatabase implements IDatabase for MySQL/MariaDB

func NewMySQLDatabase 

func NewMySQLDatabase(config DatabaseConfig) *MySQLDatabase

NewMySQLDatabase creates a new MySQL database instance

func (*MySQLDatabase) Begin 

func (m *MySQLDatabase) Begin(ctx context.Context) (ITransaction, error)

Begin starts a transaction

func (*MySQLDatabase) BeginTx 

func (m *MySQLDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (ITransaction, error)

BeginTx starts a transaction with options

func (*MySQLDatabase) BuildInsert 

func (m *MySQLDatabase) BuildInsert(tableName string, data map[string]interface{}) (string, []interface{})

BuildInsert builds an INSERT statement (stub implementation)

func (*MySQLDatabase) BuildSelect 

func (m *MySQLDatabase) BuildSelect(tableName string, columns []string, where string, orderBy string, limit int) string

BuildSelect builds a SELECT statement

func (*MySQLDatabase) BuildUpdate 

func (m *MySQLDatabase) BuildUpdate(tableName string, data map[string]interface{}, where string, whereArgs []interface{}) (string, []interface{})

BuildUpdate builds an UPDATE statement (stub implementation)

func (*MySQLDatabase) Close 

func (m *MySQLDatabase) Close() error

Close closes the database connection

func (*MySQLDatabase) Connect 

func (m *MySQLDatabase) Connect() error

Connect establishes connection to MySQL database

func (*MySQLDatabase) CreateIndex 

func (m *MySQLDatabase) CreateIndex(ctx context.Context, tableName, indexName string, columns []string, unique bool) error

CreateIndex creates an index

func (*MySQLDatabase) CreateTable 

func (m *MySQLDatabase) CreateTable(ctx context.Context, definition *TableDefinition) error

CreateTable creates a table from definition (stub implementation)

func (*MySQLDatabase) DropIndex 

func (m *MySQLDatabase) DropIndex(ctx context.Context, tableName, indexName string) error

DropIndex drops an index

func (*MySQLDatabase) DropTable 

func (m *MySQLDatabase) DropTable(ctx context.Context, tableName string) error

DropTable drops a table

func (*MySQLDatabase) Exec 

func (m *MySQLDatabase) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Exec executes a query and returns the result

func (*MySQLDatabase) GetConcatFunction 

func (m *MySQLDatabase) GetConcatFunction(fields []string) string

GetConcatFunction returns concatenation function

func (*MySQLDatabase) GetConfig 

func (m *MySQLDatabase) GetConfig() DatabaseConfig

GetConfig returns the database configuration

func (*MySQLDatabase) GetDateFunction 

func (m *MySQLDatabase) GetDateFunction() string

GetDateFunction returns current date function

func (*MySQLDatabase) GetLimitClause 

func (m *MySQLDatabase) GetLimitClause(limit, offset int) string

GetLimitClause returns MySQL-specific LIMIT clause

func (*MySQLDatabase) GetTableColumns 

func (m *MySQLDatabase) GetTableColumns(ctx context.Context, tableName string) ([]ColumnInfo, error)

GetTableColumns returns column information for a table (stub implementation)

func (*MySQLDatabase) GetType 

func (m *MySQLDatabase) GetType() DatabaseType

GetType returns the database type

func (*MySQLDatabase) IsHealthy 

func (m *MySQLDatabase) IsHealthy() bool

IsHealthy checks if database is healthy

func (*MySQLDatabase) Ping 

func (m *MySQLDatabase) Ping() error

Ping tests the database connection

func (*MySQLDatabase) Query 

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

Query executes a query and returns rows

func (*MySQLDatabase) QueryRow 

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

QueryRow executes a query and returns a single row

func (*MySQLDatabase) Quote 

func (m *MySQLDatabase) Quote(identifier string) string

Quote quotes an identifier (MySQL uses backticks)

func (*MySQLDatabase) QuoteValue 

func (m *MySQLDatabase) QuoteValue(value interface{}) string

QuoteValue quotes a value

func (*MySQLDatabase) Stats 

func (m *MySQLDatabase) Stats() sql.DBStats

Stats returns database connection statistics

func (*MySQLDatabase) SupportsReturning 

func (m *MySQLDatabase) SupportsReturning() bool

SupportsReturning returns false for MySQL

func (*MySQLDatabase) TableExists 

func (m *MySQLDatabase) TableExists(ctx context.Context, tableName string) (bool, error)

TableExists checks if a table exists

type MySQLTransaction 

type MySQLTransaction struct {
	// contains filtered or unexported fields
}

MySQLTransaction implements ITransaction for MySQL

func (*MySQLTransaction) Commit 

func (t *MySQLTransaction) Commit() error

func (*MySQLTransaction) Exec 

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

func (*MySQLTransaction) Query 

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

func (*MySQLTransaction) QueryRow 

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

func (*MySQLTransaction) Rollback 

func (t *MySQLTransaction) Rollback() error

type OracleDatabase 

type OracleDatabase struct {
	// contains filtered or unexported fields
}

OracleDatabase implements IDatabase for Oracle

func NewOracleDatabase 

func NewOracleDatabase(config DatabaseConfig) *OracleDatabase

NewOracleDatabase creates a new Oracle database instance

func (*OracleDatabase) Begin 

func (o *OracleDatabase) Begin(ctx context.Context) (ITransaction, error)

Begin starts a transaction

func (*OracleDatabase) BeginTx 

func (o *OracleDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (ITransaction, error)

BeginTx starts a transaction with options

func (*OracleDatabase) BuildInsert 

func (o *OracleDatabase) BuildInsert(tableName string, data map[string]interface{}) (string, []interface{})

BuildInsert builds an INSERT statement (stub implementation)

func (*OracleDatabase) BuildSelect 

func (o *OracleDatabase) BuildSelect(tableName string, columns []string, where string, orderBy string, limit int) string

BuildSelect builds a SELECT statement

func (*OracleDatabase) BuildUpdate 

func (o *OracleDatabase) BuildUpdate(tableName string, data map[string]interface{}, where string, whereArgs []interface{}) (string, []interface{})

BuildUpdate builds an UPDATE statement (stub implementation)

func (*OracleDatabase) Close 

func (o *OracleDatabase) Close() error

Close closes the database connection

func (*OracleDatabase) Connect 

func (o *OracleDatabase) Connect() error

Connect establishes connection to Oracle database (stub implementation)

func (*OracleDatabase) CreateIndex 

func (o *OracleDatabase) CreateIndex(ctx context.Context, tableName, indexName string, columns []string, unique bool) error

CreateIndex creates an index (stub implementation)

func (*OracleDatabase) CreateTable 

func (o *OracleDatabase) CreateTable(ctx context.Context, definition *TableDefinition) error

CreateTable creates a table from definition (stub implementation)

func (*OracleDatabase) DropIndex 

func (o *OracleDatabase) DropIndex(ctx context.Context, tableName, indexName string) error

DropIndex drops an index

func (*OracleDatabase) DropTable 

func (o *OracleDatabase) DropTable(ctx context.Context, tableName string) error

DropTable drops a table

func (*OracleDatabase) Exec 

func (o *OracleDatabase) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Exec executes a query and returns the result

func (*OracleDatabase) GetConcatFunction 

func (o *OracleDatabase) GetConcatFunction(fields []string) string

GetConcatFunction returns concatenation function

func (*OracleDatabase) GetConfig 

func (o *OracleDatabase) GetConfig() DatabaseConfig

GetConfig returns the database configuration

func (*OracleDatabase) GetDateFunction 

func (o *OracleDatabase) GetDateFunction() string

GetDateFunction returns current date function

func (*OracleDatabase) GetLimitClause 

func (o *OracleDatabase) GetLimitClause(limit, offset int) string

GetLimitClause returns Oracle-specific LIMIT clause (using ROWNUM)

func (*OracleDatabase) GetTableColumns 

func (o *OracleDatabase) GetTableColumns(ctx context.Context, tableName string) ([]ColumnInfo, error)

GetTableColumns returns column information for a table (stub implementation)

func (*OracleDatabase) GetType 

func (o *OracleDatabase) GetType() DatabaseType

GetType returns the database type

func (*OracleDatabase) IsHealthy 

func (o *OracleDatabase) IsHealthy() bool

IsHealthy checks if database is healthy

func (*OracleDatabase) Ping 

func (o *OracleDatabase) Ping() error

Ping tests the database connection

func (*OracleDatabase) Query 

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

Query executes a query and returns rows

func (*OracleDatabase) QueryRow 

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

QueryRow executes a query and returns a single row

func (*OracleDatabase) Quote 

func (o *OracleDatabase) Quote(identifier string) string

Quote quotes an identifier (Oracle uses double quotes)

func (*OracleDatabase) QuoteValue 

func (o *OracleDatabase) QuoteValue(value interface{}) string

QuoteValue quotes a value

func (*OracleDatabase) Stats 

func (o *OracleDatabase) Stats() sql.DBStats

Stats returns database connection statistics

func (*OracleDatabase) SupportsReturning 

func (o *OracleDatabase) SupportsReturning() bool

SupportsReturning returns true for Oracle (RETURNING INTO)

func (*OracleDatabase) TableExists 

func (o *OracleDatabase) TableExists(ctx context.Context, tableName string) (bool, error)

TableExists checks if a table exists (stub implementation)

type OracleTransaction 

type OracleTransaction struct {
	// contains filtered or unexported fields
}

OracleTransaction implements ITransaction for Oracle

func (*OracleTransaction) Commit 

func (t *OracleTransaction) Commit() error

func (*OracleTransaction) Exec 

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

func (*OracleTransaction) Query 

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

func (*OracleTransaction) QueryRow 

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

func (*OracleTransaction) Rollback 

func (t *OracleTransaction) Rollback() error

type PostgreSQLAdapter 

type PostgreSQLAdapter struct{}

PostgreSQLAdapter implements DBAdapter for PostgreSQL

func (*PostgreSQLAdapter) CaseInsensitiveLike 

func (p *PostgreSQLAdapter) CaseInsensitiveLike(column, pattern string) string

func (*PostgreSQLAdapter) InsertWithReturning 

func (p *PostgreSQLAdapter) InsertWithReturning(db *sql.DB, query string, args ...interface{}) (int64, error)

func (*PostgreSQLAdapter) InsertWithReturningTx 

func (p *PostgreSQLAdapter) InsertWithReturningTx(tx *sql.Tx, query string, args ...interface{}) (int64, error)

func (*PostgreSQLAdapter) TypeCast 

func (p *PostgreSQLAdapter) TypeCast(value, targetType string) string

type PostgreSQLDatabase 

type PostgreSQLDatabase struct {
	// contains filtered or unexported fields
}

PostgreSQLDatabase implements IDatabase for PostgreSQL

func NewPostgreSQLDatabase 

func NewPostgreSQLDatabase(config DatabaseConfig) *PostgreSQLDatabase

NewPostgreSQLDatabase creates a new PostgreSQL database instance

func (*PostgreSQLDatabase) Begin 

func (p *PostgreSQLDatabase) Begin(ctx context.Context) (ITransaction, error)

Begin starts a transaction

func (*PostgreSQLDatabase) BeginTx 

func (p *PostgreSQLDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (ITransaction, error)

BeginTx starts a transaction with options

func (*PostgreSQLDatabase) BuildInsert 

func (p *PostgreSQLDatabase) BuildInsert(tableName string, data map[string]interface{}) (string, []interface{})

BuildInsert builds an INSERT statement

func (*PostgreSQLDatabase) BuildSelect 

func (p *PostgreSQLDatabase) BuildSelect(tableName string, columns []string, where string, orderBy string, limit int) string

BuildSelect builds a SELECT statement

func (*PostgreSQLDatabase) BuildUpdate 

func (p *PostgreSQLDatabase) BuildUpdate(tableName string, data map[string]interface{}, where string, whereArgs []interface{}) (string, []interface{})

BuildUpdate builds an UPDATE statement

func (*PostgreSQLDatabase) Close 

func (p *PostgreSQLDatabase) Close() error

Close closes the database connection

func (*PostgreSQLDatabase) Connect 

func (p *PostgreSQLDatabase) Connect() error

Connect establishes connection to PostgreSQL database

func (*PostgreSQLDatabase) CreateIndex 

func (p *PostgreSQLDatabase) CreateIndex(ctx context.Context, tableName, indexName string, columns []string, unique bool) error

CreateIndex creates an index

func (*PostgreSQLDatabase) CreateTable 

func (p *PostgreSQLDatabase) CreateTable(ctx context.Context, definition *TableDefinition) error

CreateTable creates a table from definition

func (*PostgreSQLDatabase) DropIndex 

func (p *PostgreSQLDatabase) DropIndex(ctx context.Context, tableName, indexName string) error

DropIndex drops an index

func (*PostgreSQLDatabase) DropTable 

func (p *PostgreSQLDatabase) DropTable(ctx context.Context, tableName string) error

DropTable drops a table

func (*PostgreSQLDatabase) Exec 

func (p *PostgreSQLDatabase) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Exec executes a query and returns the result

func (*PostgreSQLDatabase) GetConcatFunction 

func (p *PostgreSQLDatabase) GetConcatFunction(fields []string) string

GetConcatFunction returns concatenation function

func (*PostgreSQLDatabase) GetConfig 

func (p *PostgreSQLDatabase) GetConfig() DatabaseConfig

GetConfig returns the database configuration

func (*PostgreSQLDatabase) GetDateFunction 

func (p *PostgreSQLDatabase) GetDateFunction() string

GetDateFunction returns current date function

func (*PostgreSQLDatabase) GetLimitClause 

func (p *PostgreSQLDatabase) GetLimitClause(limit, offset int) string

GetLimitClause returns database-specific LIMIT clause

func (*PostgreSQLDatabase) GetTableColumns 

func (p *PostgreSQLDatabase) GetTableColumns(ctx context.Context, tableName string) ([]ColumnInfo, error)

GetTableColumns returns column information for a table

func (*PostgreSQLDatabase) GetType 

func (p *PostgreSQLDatabase) GetType() DatabaseType

GetType returns the database type

func (*PostgreSQLDatabase) IsHealthy 

func (p *PostgreSQLDatabase) IsHealthy() bool

IsHealthy checks if database is healthy

func (*PostgreSQLDatabase) Ping 

func (p *PostgreSQLDatabase) Ping() error

Ping tests the database connection

func (*PostgreSQLDatabase) Query 

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

Query executes a query and returns rows

func (*PostgreSQLDatabase) QueryRow 

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

QueryRow executes a query and returns a single row

func (*PostgreSQLDatabase) Quote 

func (p *PostgreSQLDatabase) Quote(identifier string) string

Quote quotes an identifier

func (*PostgreSQLDatabase) QuoteValue 

func (p *PostgreSQLDatabase) QuoteValue(value interface{}) string

QuoteValue quotes a value

func (*PostgreSQLDatabase) Stats 

func (p *PostgreSQLDatabase) Stats() sql.DBStats

Stats returns database connection statistics

func (*PostgreSQLDatabase) SupportsReturning 

func (p *PostgreSQLDatabase) SupportsReturning() bool

SupportsReturning returns true if database supports RETURNING clause

func (*PostgreSQLDatabase) TableExists 

func (p *PostgreSQLDatabase) TableExists(ctx context.Context, tableName string) (bool, error)

TableExists checks if a table exists

type PostgreSQLTransaction 

type PostgreSQLTransaction struct {
	// contains filtered or unexported fields
}

PostgreSQLTransaction implements ITransaction for PostgreSQL

func (*PostgreSQLTransaction) Commit 

func (t *PostgreSQLTransaction) Commit() error

func (*PostgreSQLTransaction) Exec 

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

func (*PostgreSQLTransaction) Query 

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

func (*PostgreSQLTransaction) QueryRow 

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

func (*PostgreSQLTransaction) Rollback 

func (t *PostgreSQLTransaction) Rollback() error

type Query 

type Query struct {
	SQL  string
	Args []interface{}
}

Query represents a SQL query with arguments

type SQLServerDatabase 

type SQLServerDatabase struct {
	// contains filtered or unexported fields
}

SQLServerDatabase implements IDatabase for Microsoft SQL Server

func NewSQLServerDatabase 

func NewSQLServerDatabase(config DatabaseConfig) *SQLServerDatabase

NewSQLServerDatabase creates a new SQL Server database instance

func (*SQLServerDatabase) Begin 

func (s *SQLServerDatabase) Begin(ctx context.Context) (ITransaction, error)

Begin starts a transaction

func (*SQLServerDatabase) BeginTx 

func (s *SQLServerDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (ITransaction, error)

BeginTx starts a transaction with options

func (*SQLServerDatabase) BuildInsert 

func (s *SQLServerDatabase) BuildInsert(tableName string, data map[string]interface{}) (string, []interface{})

BuildInsert builds an INSERT statement (stub implementation)

func (*SQLServerDatabase) BuildSelect 

func (s *SQLServerDatabase) BuildSelect(tableName string, columns []string, where string, orderBy string, limit int) string

BuildSelect builds a SELECT statement

func (*SQLServerDatabase) BuildUpdate 

func (s *SQLServerDatabase) BuildUpdate(tableName string, data map[string]interface{}, where string, whereArgs []interface{}) (string, []interface{})

BuildUpdate builds an UPDATE statement (stub implementation)

func (*SQLServerDatabase) Close 

func (s *SQLServerDatabase) Close() error

Close closes the database connection

func (*SQLServerDatabase) Connect 

func (s *SQLServerDatabase) Connect() error

Connect establishes connection to SQL Server database (stub implementation)

func (*SQLServerDatabase) CreateIndex 

func (s *SQLServerDatabase) CreateIndex(ctx context.Context, tableName, indexName string, columns []string, unique bool) error

CreateIndex creates an index (stub implementation)

func (*SQLServerDatabase) CreateTable 

func (s *SQLServerDatabase) CreateTable(ctx context.Context, definition *TableDefinition) error

CreateTable creates a table from definition (stub implementation)

func (*SQLServerDatabase) DropIndex 

func (s *SQLServerDatabase) DropIndex(ctx context.Context, tableName, indexName string) error

DropIndex drops an index

func (*SQLServerDatabase) DropTable 

func (s *SQLServerDatabase) DropTable(ctx context.Context, tableName string) error

DropTable drops a table

func (*SQLServerDatabase) Exec 

func (s *SQLServerDatabase) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Exec executes a query and returns the result

func (*SQLServerDatabase) GetConcatFunction 

func (s *SQLServerDatabase) GetConcatFunction(fields []string) string

GetConcatFunction returns concatenation function

func (*SQLServerDatabase) GetConfig 

func (s *SQLServerDatabase) GetConfig() DatabaseConfig

GetConfig returns the database configuration

func (*SQLServerDatabase) GetDateFunction 

func (s *SQLServerDatabase) GetDateFunction() string

GetDateFunction returns current date function

func (*SQLServerDatabase) GetLimitClause 

func (s *SQLServerDatabase) GetLimitClause(limit, offset int) string

GetLimitClause returns SQL Server-specific LIMIT clause (using OFFSET/FETCH)

func (*SQLServerDatabase) GetTableColumns 

func (s *SQLServerDatabase) GetTableColumns(ctx context.Context, tableName string) ([]ColumnInfo, error)

GetTableColumns returns column information for a table (stub implementation)

func (*SQLServerDatabase) GetType 

func (s *SQLServerDatabase) GetType() DatabaseType

GetType returns the database type

func (*SQLServerDatabase) IsHealthy 

func (s *SQLServerDatabase) IsHealthy() bool

IsHealthy checks if database is healthy

func (*SQLServerDatabase) Ping 

func (s *SQLServerDatabase) Ping() error

Ping tests the database connection

func (*SQLServerDatabase) Query 

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

Query executes a query and returns rows

func (*SQLServerDatabase) QueryRow 

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

QueryRow executes a query and returns a single row

func (*SQLServerDatabase) Quote 

func (s *SQLServerDatabase) Quote(identifier string) string

Quote quotes an identifier (SQL Server uses square brackets)

func (*SQLServerDatabase) QuoteValue 

func (s *SQLServerDatabase) QuoteValue(value interface{}) string

QuoteValue quotes a value

func (*SQLServerDatabase) Stats 

func (s *SQLServerDatabase) Stats() sql.DBStats

Stats returns database connection statistics

func (*SQLServerDatabase) SupportsReturning 

func (s *SQLServerDatabase) SupportsReturning() bool

SupportsReturning returns true for SQL Server (OUTPUT clause)

func (*SQLServerDatabase) TableExists 

func (s *SQLServerDatabase) TableExists(ctx context.Context, tableName string) (bool, error)

TableExists checks if a table exists (stub implementation)

type SQLServerTransaction 

type SQLServerTransaction struct {
	// contains filtered or unexported fields
}

SQLServerTransaction implements ITransaction for SQL Server

func (*SQLServerTransaction) Commit 

func (t *SQLServerTransaction) Commit() error

func (*SQLServerTransaction) Exec 

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

func (*SQLServerTransaction) Query 

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

func (*SQLServerTransaction) QueryRow 

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

func (*SQLServerTransaction) Rollback 

func (t *SQLServerTransaction) Rollback() error

type SchemaConverter 

type SchemaConverter struct {
	// contains filtered or unexported fields
}

SchemaConverter converts between different schema formats

func NewSchemaConverter 

func NewSchemaConverter(db IDatabase) *SchemaConverter

NewSchemaConverter creates a new schema converter

func (*SchemaConverter) ExportToXML 

func (c *SchemaConverter) ExportToXML(outputPath string) error

ExportToXML exports the current database schema to XML format

func (*SchemaConverter) ImportFromXML 

func (c *SchemaConverter) ImportFromXML(xmlPath string) error

ImportFromXML creates database tables from XML schema definition

type TableDefinition 

type TableDefinition struct {
	Name        string
	Columns     []ColumnDefinition
	Indexes     []IndexDefinition
	Constraints []ConstraintDefinition
}

TableDefinition represents a database table structure

type TableSchema 

type TableSchema struct {
	Name       string                 `yaml:"name"`
	PK         string                 `yaml:"pk"` // Primary key field name (default: "id")
	Columns    map[string]ColumnDef   `yaml:"columns"`
	Indexes    []string               `yaml:"indexes"`
	Unique     []string               `yaml:"unique"`
	Timestamps bool                   `yaml:"timestamps"` // Add create_time, change_time automatically
	Meta       map[string]interface{} `yaml:"meta"`       // Driver-specific metadata
}

TableSchema represents a table definition from YAML

type Transaction 

type Transaction interface {
	Commit() error
	Rollback() error
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}

Transaction represents a database transaction

type XMLColumn 

type XMLColumn struct {
	XMLName       xml.Name `xml:"Column"`
	Name          string   `xml:"Name,attr"`
	Type          string   `xml:"Type,attr"`
	Size          *int     `xml:"Size,attr,omitempty"`
	Required      bool     `xml:"Required,attr"`
	PrimaryKey    bool     `xml:"PrimaryKey,attr,omitempty"`
	AutoIncrement bool     `xml:"AutoIncrement,attr,omitempty"`
	Default       *string  `xml:"Default,attr,omitempty"`
}

XMLColumn represents a table column in XML format

type XMLForeignKey 

type XMLForeignKey struct {
	XMLName      xml.Name `xml:"ForeignKey"`
	Name         string   `xml:"Name,attr"`
	Local        string   `xml:"Local,attr"`
	Foreign      string   `xml:"Foreign,attr"`
	ForeignTable string   `xml:"ForeignTable,attr"`
	OnDelete     *string  `xml:"OnDelete,attr,omitempty"`
	OnUpdate     *string  `xml:"OnUpdate,attr,omitempty"`
}

XMLForeignKey represents a foreign key constraint

type XMLIndex 

type XMLIndex struct {
	XMLName xml.Name         `xml:"Index"`
	Name    string           `xml:"Name,attr"`
	Unique  bool             `xml:"Unique,attr,omitempty"`
	Columns []XMLIndexColumn `xml:"Column"`
}

XMLIndex represents a table index in XML format

type XMLIndexColumn 

type XMLIndexColumn struct {
	XMLName xml.Name `xml:"Column"`
	Name    string   `xml:"Name,attr"`
}

XMLIndexColumn represents an index column

type XMLSchema 

type XMLSchema struct {
	XMLName xml.Name   `xml:"database"`
	Name    string     `xml:"Name,attr"`
	Version string     `xml:"Version,attr"`
	Tables  []XMLTable `xml:"Table"`
}

XMLSchema represents the root schema definition (inspired by OTRS XML schema format)

type XMLTable 

type XMLTable struct {
	XMLName     xml.Name        `xml:"Table"`
	Name        string          `xml:"Name,attr"`
	Columns     []XMLColumn     `xml:"Column"`
	Indexes     []XMLIndex      `xml:"Index,omitempty"`
	ForeignKeys []XMLForeignKey `xml:"ForeignKey,omitempty"`
}

XMLTable represents a database table in XML format

Source Files

View all Source files

Directories

Path Synopsis
drivers
mysql
postgres
sqlite

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.