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
Constants ¶
View Source
const ( SqlOracleLike = 1 SqlPostgresLike = 2 CommonMaxBatch = 1000 ComplexIdSeparator = "_._" )
View Source
const ( TypeDate = "Date" TypeInt = "int" TypeInt64 = "int64" TypeString = "string" TypeBool = "bool" )
View Source
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 ¶
View Source
var NullStringAsBytes = []byte("NULL")
Functions ¶
func AddItemsToPool ¶
func ConvertListToBooleanMap ¶
func ExecuteSqlFromFolder ¶
func FindIntInIntArray ¶
func GetColumnListFromMetaByIndices ¶
func GetColumnListFromMetaByIndices(meta *TableMetaData, indices []int) string
func GetComplexIdForItem ¶
func GetConnectionType ¶
func GetDBConnection ¶
func GetDBConnectionDirect ¶
func GetDateNowFunction ¶
func GetDefaultDbConnection ¶
func GetDefaultDbConnection() string
func GetExistingItems ¶
func GetIdsFromItems ¶
func GetIdsFromItems(meta *TableMetaData, items [][]string) [][]string
func GetMetaInfo ¶
func GetMetaInfo(meta *TableMetaData) string
func GetTimestampLessDay ¶
func OrderObjectsByHierarchy ¶
func PlaceStringToSqlQuery ¶
func PreExecute ¶
func ReadGlobalDBProperty ¶
func ReadItemsInBatches ¶
func SavePortionOfItems ¶
func SplitSqlSequences ¶
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)
Click to show internal directories.
Click to hide internal directories.