postgres

Documentation

Index

• Variables
• func ColumnsSql(table *Table) string
• func GenericToPostgresType(genericType *common.Type) string
• func PostgresToGenericType(postgresType string) string
• func RawToPostgres(val []byte, origType *common.Type) (string, error)
• type PgDbExecutor
  • func NewPgDbExecutor(db *sql.DB) (*PgDbExecutor, error)
  • func (e *PgDbExecutor) BulkAddRecord(args ...interface{}) error
  • func (e *PgDbExecutor) BulkFinish() error
  • func (e *PgDbExecutor) BulkInit(table string, columns ...string) error
  • func (e *PgDbExecutor) HasCapability(capability int) bool
• type PostgresFileWriter
  • func NewPostgresFileWriter(filename string) (*PostgresFileWriter, error)
  • func (w *PostgresFileWriter) Close() error
  • func (w *PostgresFileWriter) MergeTable(src *Table, dstName string, r Reader) error
• type PostgresWriter
  • func NewPostgresWriter(conf *Config) (*PostgresWriter, error)
  • func (w *PostgresWriter) Close() error
  • func (w *PostgresWriter) MergeTable(src *Table, dstName string, r Reader) error

Variables

var (
	PG_DB_EXECUTOR_VERBOSE = true
)

var PG_W_VERBOSE = true

Functions

func ColumnsSql

func ColumnsSql(table *Table) string

func GenericToPostgresType

func GenericToPostgresType(genericType *common.Type) string

func PostgresToGenericType

func PostgresToGenericType(postgresType string) string

func RawToPostgres

func RawToPostgres(val []byte, origType *common.Type) (string, error)

converts a RawBytes field into something you can * put into a regular insert statement (wrapping strings in $$ * et cetera)

Types

type PgDbExecutor

type PgDbExecutor struct {
	common.DbExecutor
	// contains filtered or unexported fields
}

func NewPgDbExecutor

func NewPgDbExecutor(db *sql.DB) (*PgDbExecutor, error)

func (*PgDbExecutor) BulkAddRecord

func (e *PgDbExecutor) BulkAddRecord(args ...interface{}) error

func (*PgDbExecutor) BulkFinish

func (e *PgDbExecutor) BulkFinish() error

func (*PgDbExecutor) BulkInit

func (e *PgDbExecutor) BulkInit(table string, columns ...string) error

func (*PgDbExecutor) HasCapability

func (e *PgDbExecutor) HasCapability(capability int) bool

type PostgresFileWriter

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

func NewPostgresFileWriter

func NewPostgresFileWriter(filename string) (*PostgresFileWriter, error)

func (*PostgresFileWriter) Close

func (w *PostgresFileWriter) Close() error

func (*PostgresFileWriter) MergeTable

func (w *PostgresFileWriter) MergeTable(src *Table, dstName string, r Reader) error

how to do an UPSERT/MERGE in PostgreSQL * http://stackoverflow.com/questions/17267417/how-do-i-do-an-upsert-merge-insert-on-duplicate-update-in-postgresq

type PostgresWriter

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

func NewPostgresWriter

func NewPostgresWriter(conf *Config) (*PostgresWriter, error)

func (*PostgresWriter) Close

func (w *PostgresWriter) Close() error

func (*PostgresWriter) MergeTable

func (w *PostgresWriter) MergeTable(src *Table, dstName string, r Reader) error

how to do an UPSERT/MERGE in PostgreSQL * http://stackoverflow.com/questions/17267417/how-do-i-do-an-upsert-merge-insert-on-duplicate-update-in-postgresq