provider

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// OracleDatabaseProviderName defines the name for Oracle database Provider
	OracleDatabaseProviderName string = "oracle"

	// SQLiteDataProviderName defines the name for SQLite database Provider
	SQLiteDataProviderName string = "sqlite"

	// MySQLDatabaseProviderName defines the name for MySQL database Provider
	MySQLDatabaseProviderName string = "mysql"

	// PostgresSQLDatabaseProviderName defines the name for PostgresSQL database Provider
	PostgresSQLDatabaseProviderName string = "postgres"

	// MemoryDataProviderName defines the name for memory provider using SQLite in-memory database Provider
	MemoryDataProviderName string = "memory"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateTableColumn added in v0.2.1 

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

func (*CreateTableColumn) PrimaryKey added in v0.2.1 

func (c *CreateTableColumn) PrimaryKey() *CreateTableColumn

PrimaryKey establece la columna como PRIMARY KEY

func (*CreateTableColumn) Type added in v0.2.1 

func (c *CreateTableColumn) Type(dataType string) *CreateTableColumn

Type establece el tipo de dato de la columna

type MemoryProvider 

type MemoryProvider struct {
	context.Context
	// contains filtered or unexported fields
}

MemoryProvider defines the auth provider for in-memory database

func NewMemoryProvider 

func NewMemoryProvider(options *Options) (*MemoryProvider, error)

NewMemoryProvider creates a new memory provider instance

func (*MemoryProvider) CheckAvailability 

func (m *MemoryProvider) CheckAvailability() error

CheckAvailability checks if the data provider is available

func (*MemoryProvider) Disconnect 

func (m *MemoryProvider) Disconnect() error

Disconnect disconnects from the data provider

func (*MemoryProvider) GetConnection 

func (m *MemoryProvider) GetConnection() *sqlx.DB

GetConnection returns the connection to the data provider

func (*MemoryProvider) GetProviderStatus 

func (m *MemoryProvider) GetProviderStatus() Status

GetProviderStatus returns the status of the provider

func (*MemoryProvider) InitializeDatabase 

func (m *MemoryProvider) InitializeDatabase(schema string) error

InitializeDatabase initializes the database

func (*MemoryProvider) MigrateDatabase 

func (m *MemoryProvider) MigrateDatabase() migration.Migration

MigrateDatabase migrates the database to the latest version

func (*MemoryProvider) ReconnectDatabase 

func (m *MemoryProvider) ReconnectDatabase() error

ReconnectDatabase reconnects to the database

func (*MemoryProvider) ResetDatabase 

func (m *MemoryProvider) ResetDatabase() error

ResetDatabase resets the database

func (*MemoryProvider) RevertDatabase 

func (m *MemoryProvider) RevertDatabase(targetVersion int) error

RevertDatabase migrates the database to the latest version

func (*MemoryProvider) SqlBuilder added in v0.2.1 

func (m *MemoryProvider) SqlBuilder() *SQLBuilder

type MySQLProvider 

type MySQLProvider struct{}

MySQLProvider defines the auth provider for MySQL/MariaDB database

func NewMySQLProvider 

func NewMySQLProvider(options *Options) (*MySQLProvider, error)

NewMySQLProvider creates a new MySQL provider instance

func (*MySQLProvider) CheckAvailability 

func (m *MySQLProvider) CheckAvailability() error

func (*MySQLProvider) Disconnect 

func (m *MySQLProvider) Disconnect() error

func (*MySQLProvider) GetConnection 

func (m *MySQLProvider) GetConnection() *sqlx.DB

func (*MySQLProvider) GetProviderStatus 

func (m *MySQLProvider) GetProviderStatus() Status

func (*MySQLProvider) InitializeDatabase 

func (m *MySQLProvider) InitializeDatabase(schema string) error

func (*MySQLProvider) MigrateDatabase 

func (m *MySQLProvider) MigrateDatabase() migration.Migration

func (*MySQLProvider) ReconnectDatabase 

func (m *MySQLProvider) ReconnectDatabase() error

func (*MySQLProvider) ResetDatabase 

func (m *MySQLProvider) ResetDatabase() error

func (*MySQLProvider) RevertDatabase 

func (m *MySQLProvider) RevertDatabase(targetVersion int) error

func (*MySQLProvider) SqlBuilder added in v0.2.1 

func (m *MySQLProvider) SqlBuilder() *SQLBuilder

type ORASQLProvider 

type ORASQLProvider struct{}

ORASQLProvider defines the auth provider for Oracle database

func NewOracleProvider 

func NewOracleProvider(options *Options) (*ORASQLProvider, error)

NewOracleProvider creates a new Oracle provider instance

func (*ORASQLProvider) CheckAvailability 

func (o *ORASQLProvider) CheckAvailability() error

func (*ORASQLProvider) Disconnect 

func (o *ORASQLProvider) Disconnect() error

func (*ORASQLProvider) GetConnection 

func (o *ORASQLProvider) GetConnection() *sqlx.DB

func (*ORASQLProvider) GetProviderStatus 

func (o *ORASQLProvider) GetProviderStatus() Status

func (*ORASQLProvider) InitializeDatabase 

func (o *ORASQLProvider) InitializeDatabase(schema string) error

func (*ORASQLProvider) MigrateDatabase 

func (o *ORASQLProvider) MigrateDatabase() migration.Migration

func (*ORASQLProvider) ReconnectDatabase 

func (o *ORASQLProvider) ReconnectDatabase() error

func (*ORASQLProvider) ResetDatabase 

func (o *ORASQLProvider) ResetDatabase() error

func (*ORASQLProvider) RevertDatabase 

func (o *ORASQLProvider) RevertDatabase(targetVersion int) error

func (*ORASQLProvider) SqlBuilder added in v0.2.1 

func (o *ORASQLProvider) SqlBuilder() *SQLBuilder

type Options 

type Options struct {
	Driver           string
	Name             string
	Host             string
	Port             int
	Username         string
	Password         string
	Schema           string
	SQLTablesPrefix  string
	PoolSize         int
	ConnectionString string
	context.Context
}

type PGSQLProvider 

type PGSQLProvider struct{}

PGSQLProvider defines the auth provider for PostgresSQL database

func NewPostgreSQLProvider 

func NewPostgreSQLProvider(options *Options) (*PGSQLProvider, error)

NewPostgreSQLProvider creates a new PostgreSQL provider instance

func (*PGSQLProvider) CheckAvailability 

func (p *PGSQLProvider) CheckAvailability() error

func (*PGSQLProvider) Disconnect 

func (p *PGSQLProvider) Disconnect() error

func (*PGSQLProvider) GetConnection 

func (p *PGSQLProvider) GetConnection() *sqlx.DB

func (*PGSQLProvider) GetProviderStatus 

func (p *PGSQLProvider) GetProviderStatus() Status

func (*PGSQLProvider) InitializeDatabase 

func (p *PGSQLProvider) InitializeDatabase(schema string) error

func (*PGSQLProvider) MigrateDatabase 

func (p *PGSQLProvider) MigrateDatabase() migration.Migration

func (*PGSQLProvider) ReconnectDatabase 

func (p *PGSQLProvider) ReconnectDatabase() error

func (*PGSQLProvider) ResetDatabase 

func (p *PGSQLProvider) ResetDatabase() error

func (*PGSQLProvider) RevertDatabase 

func (p *PGSQLProvider) RevertDatabase(targetVersion int) error

func (*PGSQLProvider) SqlBuilder added in v0.2.1 

func (p *PGSQLProvider) SqlBuilder() *SQLBuilder

type SQLBuilder added in v0.2.1 

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

SQLBuilder estructura para construir consultas SQL

func NewSQLBuilder added in v0.2.1 

func NewSQLBuilder(driver string) *SQLBuilder

NewSQLBuilder crea una nueva instancia de SQLBuilder

func (*SQLBuilder) Build added in v0.2.1 

func (b *SQLBuilder) Build() string

Build construye la consulta SQL

func (*SQLBuilder) Column added in v0.2.1 

func (b *SQLBuilder) Column(name string) *CreateTableColumn

Column agrega una columna a la consulta CREATE TABLE

func (*SQLBuilder) Columns added in v0.2.1 

func (b *SQLBuilder) Columns(columns ...*CreateTableColumn) *SQLBuilder

Columns agrega las columnas a la consulta CREATE TABLE

func (*SQLBuilder) CreateTable added in v0.2.1 

func (b *SQLBuilder) CreateTable(table string) *SQLBuilder

CreateTable establece la tabla para la consulta CREATE TABLE

func (*SQLBuilder) Drop added in v0.2.1 

func (b *SQLBuilder) Drop() string

func (*SQLBuilder) GroupBy added in v0.2.1 

func (b *SQLBuilder) GroupBy(columns ...string) *SQLBuilder

GroupBy establece la cláusula GROUP BY

func (*SQLBuilder) IfNotExists added in v0.2.1 

func (b *SQLBuilder) IfNotExists() *SQLBuilder

IfNotExists agrega la opción IF NOT EXISTS a la consulta CREATE TABLE

func (*SQLBuilder) Insert added in v0.2.1 

func (b *SQLBuilder) Insert(columns ...string) *SQLBuilder

Insert establece la tabla y columnas para la consulta INSERT

func (*SQLBuilder) Join added in v0.2.1 

func (b *SQLBuilder) Join(join string) *SQLBuilder

Join agrega una cláusula JOIN

func (*SQLBuilder) Limit added in v0.2.1 

func (b *SQLBuilder) Limit(limit int) *SQLBuilder

Limit establece la cláusula LIMIT

func (*SQLBuilder) Offset added in v0.2.1 

func (b *SQLBuilder) Offset(offset int) *SQLBuilder

Offset establece la cláusula OFFSET

func (*SQLBuilder) OrderBy added in v0.2.1 

func (b *SQLBuilder) OrderBy(columns ...string) *SQLBuilder

OrderBy establece la cláusula ORDER BY

func (*SQLBuilder) Schema added in v0.2.1 

func (b *SQLBuilder) Schema(schema string) *SQLBuilder

Schema establece el esquema de la tabla

func (*SQLBuilder) Select added in v0.2.1 

func (b *SQLBuilder) Select(columns ...string) *SQLBuilder

Select establece las columnas a seleccionar

func (*SQLBuilder) Set added in v0.2.1 

func (b *SQLBuilder) Set(values map[string]any) *SQLBuilder

Set establece las columnas y valores para la consulta UPDATE

func (*SQLBuilder) Table added in v0.2.1 

func (b *SQLBuilder) Table(table string) *SQLBuilder

func (*SQLBuilder) Truncate added in v0.2.1 

func (b *SQLBuilder) Truncate() string

func (*SQLBuilder) Update added in v0.2.1 

func (b *SQLBuilder) Update() *SQLBuilder

Update establece la tabla para la consulta UPDATE

func (*SQLBuilder) Values added in v0.2.1 

func (b *SQLBuilder) Values(values ...string) *SQLBuilder

Values establece los valores para la consulta INSERT

func (*SQLBuilder) Where added in v0.2.1 

func (b *SQLBuilder) Where(condition string) *SQLBuilder

Where agrega una condición WHERE

type SQLiteProvider 

type SQLiteProvider struct {
	context.Context
	// contains filtered or unexported fields
}

SQLiteProvider defines the auth provider for SQLite database

func NewSQLiteProvider 

func NewSQLiteProvider(options *Options) (*SQLiteProvider, error)

NewSQLiteProvider creates a new SQLite provider instance

func (*SQLiteProvider) CheckAvailability 

func (s *SQLiteProvider) CheckAvailability() error

CheckAvailability checks if the data provider is available

func (*SQLiteProvider) Disconnect 

func (s *SQLiteProvider) Disconnect() error

Disconnect disconnects from the data provider

func (*SQLiteProvider) GetConnection 

func (s *SQLiteProvider) GetConnection() *sqlx.DB

GetConnection returns the connection to the data provider

func (*SQLiteProvider) GetProviderStatus 

func (s *SQLiteProvider) GetProviderStatus() Status

GetProviderStatus returns the status of the provider

func (*SQLiteProvider) InitializeDatabase 

func (s *SQLiteProvider) InitializeDatabase(schema string) error

InitializeDatabase initializes the database

func (*SQLiteProvider) MigrateDatabase 

func (s *SQLiteProvider) MigrateDatabase() migration.Migration

MigrateDatabase migrates the database to the latest version

func (*SQLiteProvider) ReconnectDatabase 

func (s *SQLiteProvider) ReconnectDatabase() error

ReconnectDatabase reconnects to the database

func (*SQLiteProvider) ResetDatabase 

func (s *SQLiteProvider) ResetDatabase() error

ResetDatabase resets the database

func (*SQLiteProvider) RevertDatabase 

func (s *SQLiteProvider) RevertDatabase(targetVersion int) error

RevertDatabase reverts the database to the specified version

func (*SQLiteProvider) SqlBuilder added in v0.2.1 

func (s *SQLiteProvider) SqlBuilder() *SQLBuilder

type Status 

type Status struct {
	Driver   string `json:"driver"`
	Error    error  `json:"error"`
	IsActive bool   `json:"is_active"`
}

Source Files

View all Source files

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.