drivers

Documentation

Index

• Constants
• type Driver
  • func New(f Flags) Driver
• type FKDescriptor
• type Field
• type FieldDescriptor
• type Flags
• type MySQL
  • func (m MySQL) Connection() string
  • func (MySQL) Describe(table string, db *sql.DB) ([]FieldDescriptor, error)
  • func (m MySQL) Driver() string
  • func (MySQL) GetLatestColumnValue(table, column string, db *sql.DB) (interface{}, error)
  • func (MySQL) GetTestCase(name string) (TestCase, error)
  • func (m MySQL) Insert(fields []string, table string) string
  • func (m MySQL) MapField(descriptor FieldDescriptor) Field
  • func (m MySQL) MultiDescribe(tables []string, db *sql.DB) (map[string][]FieldDescriptor, []string, error)
  • func (m MySQL) ShowTables(db *sql.DB) ([]string, error)
  • func (m MySQL) TestTable(db *sql.DB, testCase, table string) error
• type Postgres
  • func (p Postgres) Connection() string
  • func (p Postgres) Describe(table string, db *sql.DB) ([]FieldDescriptor, error)
  • func (p Postgres) Driver() string
  • func (p Postgres) GetLatestColumnValue(table, column string, db *sql.DB) (interface{}, error)
  • func (Postgres) GetTestCase(name string) (TestCase, error)
  • func (p Postgres) Insert(fields []string, table string) string
  • func (p Postgres) MapField(descriptor FieldDescriptor) Field
  • func (p Postgres) MultiDescribe(tables []string, db *sql.DB) (map[string][]FieldDescriptor, []string, error)
  • func (p Postgres) ShowTables(db *sql.DB) ([]string, error)
  • func (p Postgres) TestTable(db *sql.DB, testCase, table string) error
• type TestCase
• type Testable
  • func NewTestable(f Flags) Testable
• type Type

Examples

• Postgres.ShowTables

Constants

const (
	PSQLDescribeTemplate   = "" /* 172-byte string literal not displayed */
	PSQLConnectionTemplate = "host=%s port=%s user=%s password=%s dbname=%s sslmode=disable"
	PSQLInsertTemplate     = `INSERT INTO %s("%s") VALUES(%s)`
	PSQLShowTablesQuery    = "SELECT tablename FROM pg_catalog.pg_tables WHERE schemaname != 'pg_catalog' AND schemaname != 'information_schema';"
)

const CreateTable = `` /* 1246-byte string literal not displayed */

Below columns are not yet implemented and removed from table. Add these once implemented. col20 cidr col24 inet col30 line col31 macaddr col32 money

const (
	DefaultTableCreateQueryKey = ""
)

const (
	MySQLDescribeTableQuery = "SHOW TABLES;"
)

Types

type Driver

type Driver interface {
	ShowTables(db *sql.DB) ([]string, error)
	Connection() string
	Driver() string
	Insert(fields []string, table string) string
	MapField(descriptor FieldDescriptor) Field
	Describe(table string, db *sql.DB) ([]FieldDescriptor, error)
	MultiDescribe(tables []string, db *sql.DB) (map[string][]FieldDescriptor, []string, error)
	GetLatestColumnValue(table, column string, db *sql.DB) (interface{}, error)
}

Driver is the interface should satisfied by a certain driver

func New

func New(f Flags) Driver

New creates a new driver instance based on the flags

type FKDescriptor

type FKDescriptor struct {
	ConstraintName    string
	TableName         string
	ColumnName        string
	ForeignTableName  string
	ForeignColumnName string
}

type Field

type Field struct {
	Type   Type
	Length int16
	Enum   []string
}

Field is the possible field definition

type FieldDescriptor

type FieldDescriptor struct {
	Field                string
	Type                 string
	Null                 string
	Key                  string
	Length               null.Int
	Default              null.String
	Extra                string
	Precision            null.Int
	Scale                null.Int
	HasDefaultValue      bool
	ForeignKeyDescriptor *FKDescriptor
}

FieldDescriptor represents a field described by the table in the SQL database

type Flags

type Flags struct {
	Username string
	Password string
	Database string
	Host     string
	Port     string
	Driver   string
}

Flags needed by the driver

type MySQL

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

MySQL implementation of the Driver

func (MySQL) Connection

func (m MySQL) Connection() string

Connection returns the specific connection string

func (MySQL) Describe

func (MySQL) Describe(table string, db *sql.DB) ([]FieldDescriptor, error)

func (MySQL) Driver

func (m MySQL) Driver() string

Driver returns the name of the driver

func (MySQL) GetLatestColumnValue

func (MySQL) GetLatestColumnValue(table, column string, db *sql.DB) (interface{}, error)

func (MySQL) GetTestCase

func (MySQL) GetTestCase(name string) (TestCase, error)

func (MySQL) Insert

func (m MySQL) Insert(fields []string, table string) string

Insert inserts the data into

func (MySQL) MapField

func (m MySQL) MapField(descriptor FieldDescriptor) Field

MapField returns the actual fields

func (MySQL) MultiDescribe

func (m MySQL) MultiDescribe(tables []string, db *sql.DB) (map[string][]FieldDescriptor, []string, error)

func (MySQL) ShowTables

func (m MySQL) ShowTables(db *sql.DB) ([]string, error)

func (MySQL) TestTable

func (m MySQL) TestTable(db *sql.DB, testCase, table string) error

TestTable only for test purposes

type Postgres

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

func (Postgres) Connection

func (p Postgres) Connection() string

func (Postgres) Describe

func (p Postgres) Describe(table string, db *sql.DB) ([]FieldDescriptor, error)

func (Postgres) Driver

func (p Postgres) Driver() string

func (Postgres) GetLatestColumnValue

func (p Postgres) GetLatestColumnValue(table, column string, db *sql.DB) (interface{}, error)

func (Postgres) GetTestCase

func (Postgres) GetTestCase(name string) (TestCase, error)

func (Postgres) Insert

func (p Postgres) Insert(fields []string, table string) string

func (Postgres) MapField

func (p Postgres) MapField(descriptor FieldDescriptor) Field

func (Postgres) MultiDescribe

func (p Postgres) MultiDescribe(tables []string, db *sql.DB) (map[string][]FieldDescriptor, []string, error)

func (Postgres) ShowTables

func (p Postgres) ShowTables(db *sql.DB) ([]string, error)

Example

createTable()
db, err := getPostgresConnection()
if err != nil {
	return
}
driver := Postgres{}
tables, err := driver.ShowTables(db)
if err != nil {
	log.Printf("Error showing tables : %s", err.Error())
	return
}
for _, table := range tables {
	fmt.Println(table)
}

func (Postgres) TestTable

func (p Postgres) TestTable(db *sql.DB, testCase, table string) error

TestTable only for test purposes

type TestCase

type TestCase struct {
	TableToCreateQueryMap map[string]string
	TableCreationOrder    []string
}

TestCase has a map of table to its create table query and table creation order

type Testable

type Testable interface {
	GetTestCase(name string) (TestCase, error)
	TestTable(conn *sql.DB, testCase, table string) error
}

func NewTestable

func NewTestable(f Flags) Testable

type Type

type Type int16

const (
	String Type = iota
	Int16
	Int32
	Float
	Blob // base64
	Text
	Enum
	Bool
	Json
	Time
	Year
	XML
	UUID
	BinaryString
	Unknown
)