dvdbdata

package

v1.0.0 Latest Latest Go to latest Published: May 16, 2020 License: MIT Imports: 17 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Dobryvechir/microcore

Links

Open Source Insights

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 ¶

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 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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL