Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsMySqlConnectionString ¶
IsMySqlConnectionString returns true if the connection string is for mysql looks for the mysql:// prefix
func IsPostgresConnectionString ¶
IsPostgresConnectionString returns true if the connection string is for postgres looks for the postgresql:// or postgres:// prefix
func IsSqliteConnectionString ¶
IsSqliteConnectionString returns true if the connection string is for sqlite looks for the sqlite:// prefix
func NewGenericSQLRowReader ¶
func NewGenericSQLRowReader() *genericSQLRowReader
func NewPgxRowReader ¶
func NewPgxRowReader() *pgxRowReader
Types ¶
type DBClientBackendType ¶
type DBClientBackendType int
const ( PostgresDBClientBackend DBClientBackendType = iota MySQLDBClientBackend SqliteDBClientBackend )
func GetBackendFromConnectionString ¶
func GetBackendFromConnectionString(ctx context.Context, connectionString string) (DBClientBackendType, error)
type RowReader ¶
type RowReader interface {
Read(columnValues []any, cols []*queryresult.ColumnDef) ([]any, error)
}
func NewMySqlRowReader ¶
func NewMySqlRowReader() RowReader
func RowReaderFactory ¶
func RowReaderFactory(backend DBClientBackendType) RowReader
Source Files
Click to show internal directories.
Click to hide internal directories.