dvdbdata

Documentation

Index

• Constants
• Variables
• func AddItemsToPool(db *sql.DB, sql string, cols int, pool [][]string) ([][]string, error)
• func ConvertListToBooleanMap(ids []string) map[string]bool
• func CreateTableByDefinition(db *sql.DB, def string) error
• func ExecuteSqlData(db *sql.DB, data []byte) error
• func ExecuteSqlFromFile(db *sql.DB, fileName string) error
• func ExecuteSqlFromFolder(db *sql.DB, root string, sqlName string) error
• func FindIntInIntArray(val int, data []int) int
• func GetColumnListFromMetaByIndices(meta *TableMetaData, indices []int) string
• func GetComplexIdForItem(row []string, ids []int) string
• func GetConnectionType(connName string) int
• func GetDB(connName string) (*sql.DB, string, error)
• func GetDBConnection(props map[string]string, connName string) (*sql.DB, string, error)
• func GetDBConnectionDirect(props map[string]string, connName string) (*sql.DB, string, error)
• func GetDateNowFunction(sqlType int) string
• func GetDefaultDbConnection() string
• func GetExistingItems(meta *TableMetaData, ids [][]string, db *sql.DB) ([]string, error)
• func GetIdsFromItems(meta *TableMetaData, items [][]string) [][]string
• func GetMetaInfo(meta *TableMetaData) string
• func GetPropertyGlobalDefinition(props map[string]string) string
• func GetSingleValuesFromString(data [][]string, column int) []string
• func GetTableNameColumnsFromDefinition(def string) (table string, columns []string, colDef []string, err error)
• func GetTimestampLessDay(sqlType int) string
• func OrderObjectsByHierarchy(objects [][]string, leftObjects map[string]bool, idCol int, depCols []int) ([][][]string, error)
• func PlaceStringToSqlQuery(v string, tp string, b []byte, options int) ([]byte, error)
• func PreExecute(properties map[string]string) error
• func PreExecuteCsvFile(conn *sql.DB, name string, options int) error
• func PreExecuteForNewerVersions(props map[string]string, db *sql.DB, folder string, sqlName string) error
• func ReadGlobalDBProperty(props map[string]string, db *sql.DB, name string, defValue string) (string, error)
• func ReadItemsInBatches(db *sql.DB, start string, finish string, ids []string, cols int) ([][]string, error)
• func SavePortionOfItems(items [][]string, sqlTable string, conn *sql.DB, left map[string]bool, ...) (err error)
• func SplitSqlSequences(data []byte) []string
• func SqlInit(command string, ctx *dvmeta.RequestContext) ([]interface{}, bool)
• func SqlRun(data []interface{}) bool
• func SqlSingleValueByConnection(db *sql.DB, query string) (string, bool, error)
• func SqlSingleValueByConnectionName(connName string, query string) (string, bool, error)
• func SqlUpdateByConnection(db *sql.DB, query string) error
• func SqlUpdateByConnectionName(connName string, query string) error
• func WriteGlobalDBProperty(props map[string]string, db *sql.DB, name string, value string) error
• type SqlAction
• type TableMetaData
  • func ReadTableMetaData(table string, props map[string]string) (*TableMetaData, error)

Constants

const (
	SqlOracleLike      = 1
	SqlPostgresLike    = 2
	CommonMaxBatch     = 1000
	ComplexIdSeparator = "_._"
)

const (
	TypeDate   = "Date"
	TypeInt    = "int"
	TypeInt64  = "int64"
	TypeString = "string"
	TypeBool   = "bool"
)

const (
	SQL_KIND_UPDATE     = 0
	SQL_KIND_SINGLE     = 1
	SQL_KIND_ROW        = 2
	SQL_KIND_TABLE      = 3
	SQL_KIND_LIST       = 4
	SQL_KIND_ROW_TEXT   = 5
	SQL_KIND_TABLE_TEXT = 6
)

Variables

var NullStringAsBytes = []byte("NULL")

Functions

func AddItemsToPool

func AddItemsToPool(db *sql.DB, sql string, cols int, pool [][]string) ([][]string, error)

func ConvertListToBooleanMap

func ConvertListToBooleanMap(ids []string) map[string]bool

func CreateTableByDefinition

func CreateTableByDefinition(db *sql.DB, def string) error

func ExecuteSqlData

func ExecuteSqlData(db *sql.DB, data []byte) error

func ExecuteSqlFromFile

func ExecuteSqlFromFile(db *sql.DB, fileName string) error

func ExecuteSqlFromFolder

func ExecuteSqlFromFolder(db *sql.DB, root string, sqlName string) error

func FindIntInIntArray

func FindIntInIntArray(val int, data []int) int

func GetColumnListFromMetaByIndices

func GetColumnListFromMetaByIndices(meta *TableMetaData, indices []int) string

func GetComplexIdForItem

func GetComplexIdForItem(row []string, ids []int) string

func GetConnectionType

func GetConnectionType(connName string) int

func GetDB

func GetDB(connName string) (*sql.DB, string, error)

func GetDBConnection

func GetDBConnection(props map[string]string, connName string) (*sql.DB, string, error)

func GetDBConnectionDirect

func GetDBConnectionDirect(props map[string]string, connName string) (*sql.DB, string, error)

func GetDateNowFunction

func GetDateNowFunction(sqlType int) string

func GetDefaultDbConnection

func GetDefaultDbConnection() string

func GetExistingItems

func GetExistingItems(meta *TableMetaData, ids [][]string, db *sql.DB) ([]string, error)

func GetIdsFromItems

func GetIdsFromItems(meta *TableMetaData, items [][]string) [][]string

func GetMetaInfo

func GetMetaInfo(meta *TableMetaData) string

func GetPropertyGlobalDefinition

func GetPropertyGlobalDefinition(props map[string]string) string

func GetSingleValuesFromString

func GetSingleValuesFromString(data [][]string, column int) []string

func GetTableNameColumnsFromDefinition

func GetTableNameColumnsFromDefinition(def string) (table string, columns []string, colDef []string, err error)

func GetTimestampLessDay

func GetTimestampLessDay(sqlType int) string

func OrderObjectsByHierarchy

func OrderObjectsByHierarchy(objects [][]string, leftObjects map[string]bool,
	idCol int, depCols []int) ([][][]string, error)

func PlaceStringToSqlQuery

func PlaceStringToSqlQuery(v string, tp string, b []byte, options int) ([]byte, error)

func PreExecute

func PreExecute(properties map[string]string) error

func PreExecuteCsvFile

func PreExecuteCsvFile(conn *sql.DB, name string, options int) error

func PreExecuteForNewerVersions

func PreExecuteForNewerVersions(props map[string]string, db *sql.DB, folder string, sqlName string) error

func ReadGlobalDBProperty

func ReadGlobalDBProperty(props map[string]string, db *sql.DB, name string, defValue string) (string, error)

func ReadItemsInBatches

func ReadItemsInBatches(db *sql.DB, start string, finish string, ids []string, cols int) ([][]string, error)

func SavePortionOfItems

func SavePortionOfItems(items [][]string, sqlTable string, conn *sql.DB, left map[string]bool,
	columnIds []int, options int, types []string) (err error)

func SplitSqlSequences

func SplitSqlSequences(data []byte) []string

func SqlInit

func SqlInit(command string, ctx *dvmeta.RequestContext) ([]interface{}, bool)

func SqlRun

func SqlRun(data []interface{}) bool

func SqlSingleValueByConnection

func SqlSingleValueByConnection(db *sql.DB, query string) (string, bool, error)

func SqlSingleValueByConnectionName

func SqlSingleValueByConnectionName(connName string, query string) (string, bool, error)

func SqlUpdateByConnection

func SqlUpdateByConnection(db *sql.DB, query string) error

func SqlUpdateByConnectionName

func SqlUpdateByConnectionName(connName string, query string) error

func WriteGlobalDBProperty

func WriteGlobalDBProperty(props map[string]string, db *sql.DB, name string, value string) error

Types

type SqlAction

type SqlAction struct {
	Db           string   `json:"db"`
	Query        string   `json:"query"`
	QueryOracle  string   `json:"queryOracle"`
	QueryPostgre string   `json:"queryPostgre"`
	Result       string   `json:"result"`
	Kind         string   `json:"kind"`
	Columns      []string `json:"columns"`
	Empty        int      `json:"empty"`
	Error        string   `json:"error"`
	KindNo       int
}

type TableMetaData

type TableMetaData struct {
	Id           string   `json:"id"`
	Name         string   `json:"name"`
	Dependencies []int    `json:"dependencies"`
	IdColumns    []int    `json:"idColumns"`
	MajorColumn  int      `json:"majorColumn"`
	Types        []string `json:"types"`
	Columns      []string `json:"columns"`
	QuoteColumns bool     `json:"quoteColumns"`
}

func ReadTableMetaData

func ReadTableMetaData(table string, props map[string]string) (*TableMetaData, error)