database

Documentation

Index

• func GetDatabaseName(datasource string) (string, error)
• func GetSessionFromTestingDB() *proto.Session
• func GetTestingHiveURL() string
• func GetTestingMySQLConfig() *mysql.Config
• func GetTestingMySQLURL() string
• func ParseURL(url string) (string, string, error)
• type DB
  • func GetTestingDBSingleton() *DB
  • func OpenAndConnectDB(url string) (*DB, error)
  • func OpenDB(url string) (*DB, error)
  • func (db *DB) URL() string

Functions

func GetDatabaseName

func GetDatabaseName(datasource string) (string, error)

GetDatabaseName parse the database name (or MaxCompute project) from the database connection string

func GetSessionFromTestingDB

func GetSessionFromTestingDB() *proto.Session

GetSessionFromTestingDB construct a proto message Session representing the testing database configuration.

func GetTestingHiveURL

func GetTestingHiveURL() string

GetTestingHiveURL reutrns Hive connection URL

func GetTestingMySQLConfig

func GetTestingMySQLConfig() *mysql.Config

GetTestingMySQLConfig construct a MySQL config

func GetTestingMySQLURL

func GetTestingMySQLURL() string

GetTestingMySQLURL returns MySQL connection URL

func ParseURL

func ParseURL(url string) (string, string, error)

ParseURL splits the URL into Drivername and DataSourceName.

Types

type DB

type DB struct {
	DriverName     string // NOTE: Don't name it Driver, because Driver is a method of sql.DB.
	DataSourceName string
	*sql.DB
}

DB extends sql.DB, while keeping the two parameters, DriverName and DataSource, to database/sql.Open reaccessible.

func GetTestingDBSingleton

func GetTestingDBSingleton() *DB

GetTestingDBSingleton returns the testing DB singleton.

func OpenAndConnectDB

func OpenAndConnectDB(url string) (*DB, error)

OpenAndConnectDB calls OpenDB to open a database specified by an URL. In addition to opening, it also call database.DB.Ping to ensure a connection to the database.

func OpenDB

func OpenDB(url string) (*DB, error)

OpenDB open a database identified by an URL. It calls ParseURL to get the driver and data source name. In addition to opening the database, it also verifies the driver is loaded.

func (*DB) URL

func (db *DB) URL() string

URL calls unparseURL to build the URL from DriverName and DataSourceName.