storage

Documentation

Index

• type DbType
  • func ConvertToDbType(value string) (DbType, error)
• type Storage
  • func NewStorage(dbType DbType, connection string, tableName string) (*Storage, error)
  • func NewStorageFinalized(db *sql.DB, dbType DbType, tableName string) (*Storage, error)
  • func (db *Storage) Close() (err error)
  • func (db *Storage) Exec(query string, args ...interface{}) (*sql.Result, error)
  • func (db *Storage) Query(query string, args ...interface{}) (*sql.Rows, error)

Types

type DbType

type DbType int

DbType defines the type of the db

const (
	MSSQL      DbType = iota // MS SQL Server
	PostgreSQL               // Postgresql
)

Relational Db Types

func ConvertToDbType

func ConvertToDbType(value string) (DbType, error)

ConvertToDbType convert's a string to a DbType

type Storage

type Storage struct {
	DbType                    DbType
	AppendStatement           string
	SelectBySourceIDStatement string
	// contains filtered or unexported fields
}

Storage a db abstraction

func NewStorage

func NewStorage(dbType DbType, connection string, tableName string) (*Storage, error)

NewStorage creates a new storage

func NewStorageFinalized

func NewStorageFinalized(db *sql.DB, dbType DbType, tableName string) (*Storage, error)

NewStorageFinalized creates a new storage with a passed in db argument

func (*Storage) Close

func (db *Storage) Close() (err error)

Close close db

func (*Storage) Exec

func (db *Storage) Exec(query string, args ...interface{}) (*sql.Result, error)

Exec executes sql statement

func (*Storage) Query

func (db *Storage) Query(query string, args ...interface{}) (*sql.Rows, error)

Query executes a query statement