Versions in this module Expand all Collapse all v1 v1.0.1 Mar 9, 2021 Changes in this version + const DB_CONN_POSTGRES + type DBColumnDefinition struct + ColumnName string + ColumnType reflect.Type + type DBConn interface + AddTableColumn func(tableName string, column DBColumnDefinition) error + CreateTable func(tableName string, columns []DBColumnDefinition) error + CreateTableIfNotExists func(tableName string, columns []DBColumnDefinition) error + DoesTableColumnExist func(tableName string, columnName string) (bool, error) + DoesTableExist func(tableName string) (bool, error) + GetConnection func() (*sql.DB, error) + GetRows func(tableName string, wheres map[string]interface{}) (*sql.Rows, error) + GetRowsSelect func(tableName string, selects []string) (*sql.Rows, error) + GetRowsSelectWhere func(tableName string, selects []string, wheres map[string]interface{}) (*sql.Rows, error) + GetSelectAllColumnsSingle func(tableName string) (*sql.Rows, error) + GetSelectSingle func(tableName string, selects []string) (*sql.Rows, error) + GetTableRowCount func(tableName string) (int, error) + GetTableSize func(tableName string) (int64, error) + InsertRowAndReturnID func(tableName string, values map[string]interface{}) int + ProfilesByType func(columnType string) map[string]string + func GetDBConnByType(dbType string, dbConnString string) (DBConn, error) + type PostgresConn struct + func NewPostgresConn(dataSourceName string) *PostgresConn + func (p *PostgresConn) AddTableColumn(tableName string, column DBColumnDefinition) error + func (p *PostgresConn) AddTableColumns(tableName string, columns []DBColumnDefinition) error + func (p *PostgresConn) CreateTable(tableName string, columns []DBColumnDefinition) error + func (p *PostgresConn) CreateTableIfNotExists(tableName string, columns []DBColumnDefinition) error + func (p *PostgresConn) DoesTableColumnExist(tableName string, columnName string) (bool, error) + func (p *PostgresConn) DoesTableExist(tableName string) (bool, error) + func (p *PostgresConn) GetConnection() (*sql.DB, error) + func (p *PostgresConn) GetRows(tableName string, wheres map[string]interface{}) (*sql.Rows, error) + func (p *PostgresConn) GetRowsSelect(tableName string, selects []string) (*sql.Rows, error) + func (p *PostgresConn) GetRowsSelectWhere(tableName string, selects []string, wheres map[string]interface{}) (*sql.Rows, error) + func (p *PostgresConn) GetSelectAllColumnsSingle(tableName string) (*sql.Rows, error) + func (p *PostgresConn) GetSelectSingle(tableName string, selects []string) (*sql.Rows, error) + func (p *PostgresConn) GetTableRowCount(tableName string) (int, error) + func (p *PostgresConn) GetTableSize(tableName string) (int64, error) + func (p *PostgresConn) InsertRowAndReturnID(tableName string, values map[string]interface{}) int + func (p *PostgresConn) ProfilesByType(columnType string) map[string]string