sql

package

Go to main page

Versions in this module

v1

v1.5.5

May 18, 2020

Changes in this version

+ func ConvertUUID(v interface{}) (string, error)

v1.5.4

Aug 20, 2019

Changes in this version

+ const CacheMapFile

+ const DefaultDoneSqlsFile

+ const SqlOffsetConnector

+ const SqlSpliter

+ const TimestampRecordsFile

+ func CheckMagic(rawSql string) (valid bool)

+ func CompareRemainStr(target, magicRemainStr, magicRet string, magicRemainIndex []int) bool

+ func CompareTime(target, match string, timeStart, timeEnd []int, min bool) (valid bool)

+ func CompareWithStartTime(data models.Data, timestampKey string, startTime time.Time) (int, bool)

+ func CompareWithStartTimeInt(data models.Data, timestampKey string, startTimeInt int64) (int, bool)

+ func CompareWithStartTimeStr(data models.Data, timestampKey, startTimeStr string) (int, bool)

+ func Contains(slice []string, str string) bool

+ func ConvertBool(v interface{}) (bool, error)

+ func ConvertDate(v interface{}) (time.Time, error)

+ func ConvertFloat(v interface{}) (float64, error)

+ func ConvertLong(v interface{}) (int64, error)

+ func ConvertMagicIndex(magic string, now time.Time) (Ret string, index int)

+ func ConvertScanArgs(data models.Data, scanArg interface{}, column, runnerName, name string, ...) (int64, error)

+ func ConvertString(v interface{}) (string, error)

+ func EqualTime(target, magicRet string, timeStart, timeEnd []int) (valid bool)

+ func GetInitScans(length int, rows *sql.Rows, schemas map[string]string, runnerName, name string) (scanArgs []interface{}, nochoiced []bool)

+ func GetOffsetIndex(offsetKey string, columns []string) int

+ func GetOffsetIndexWithTimeStamp(offsetKey, timestampKey string, columns []string) int

+ func GetRemainStr(origin string, magicRemainIndex []int) (remainStr string)

+ func GetTimeFromArgs(offsetKeyIndex int, scanArgs []interface{}) (time.Time, bool)

+ func GetTimeFromData(data models.Data, timestampKey string) (time.Time, bool)

+ func GetTimeIntFromArgs(offsetKeyIndex int, scanArgs []interface{}) (int64, bool)

+ func GetTimeIntFromData(data models.Data, timestampKey string) (int64, bool)

+ func GetTimeStrFromData(data models.Data, timestampKey string) (string, bool)

+ func OpenSql(dbtype, connectStr string) (db *sql.DB, err error)

+ func QueryNumber(tsql string, db *sql.DB) (int64, error)

+ func RemoveWildcards(checkWildcards string, length int) int

+ func RestoreMeta(meta *reader.Meta, rawSqls string, magicLagDur time.Duration) (offsets []int64, sqls []string, omitMeta bool)

+ func RestoreSqls(meta *reader.Meta) map[string]string

+ func RestoreTimestampIntOffset(doneFilePath string) (int64, map[string]string, error)

+ func RestoreTimestampOffset(doneFilePath string) (time.Time, map[string]string, error)

+ func RestoreTimestampStrOffset(doneFilePath string) (string, map[string]string, error)

+ func SchemaCheck(rawSchemas []string) (schemas map[string]string, err error)

+ func UpdateSqls(rawsqls string, now time.Time) []string

+ func WriteCacheMap(doneFilePath string, cache map[string]string) (err error)

+ func WriteSqlsFile(doneFilePath, content string) (err error)

+ func WriteTimestampOffset(doneFilePath, content string) (err error)

+ type ByJson []jsonIndex

+ func (a ByJson) Len() int

+ func (a ByJson) Less(i, j int) bool

+ func (a ByJson) Swap(i, j int)

type MagicRes

+ RemainIndex []int

+ Ret string

+ TimeEnd []int

+ TimeStart []int

+ func GoMagicIndex(rawSql string, now time.Time) (MagicRes, error)

+ type ReadInfo struct

+ Bytes int64

+ Data models.Data

+ Json string

+ func GetJson(datas []ReadInfo) ([]ReadInfo, bool)

+ func SortByJson(datas []ReadInfo) ([]ReadInfo, bool)

type SyncDBRecords

+ Mutex sync.RWMutex

+ Records DBRecords

+ func (dbRecords *SyncDBRecords) RestoreRecordsFile(meta *reader.Meta) (lastDB, lastTable string, omitDoneDBRecords bool)

+ func (syncDBRecords *SyncDBRecords) CheckDoneRecords(target, curDB string) bool

type TableInfo

+ Offset int64

+ Size int64

type TableRecords

+ Mutex sync.RWMutex

+ func (tableRecords *TableRecords) RestoreTableDone(meta *reader.Meta, database string, tables []string) bool

v1.5.3

Sep 4, 2018

Changes in this version

+ const COUNTFUNC

+ const READFUNC

+ type MagicRes struct

v1.5.2

Jul 30, 2018

Changes in this version

+ const DefaultMSSQLTable

type DBRecords

+ func (dbRecords *DBRecords) SetTableInfo(db, table string, tableInfo TableInfo)

type SyncDBRecords

+ func (syncDBRecords *SyncDBRecords) SetTableInfo(db, table string, tableInfo TableInfo)

type TableRecords

+ Table map[string]TableInfo

+ func (tableRecords *TableRecords) GetTable() map[string]TableInfo

v1.5.1

Jul 13, 2018

Changes in this version

+ type SyncDBRecords struct

+ func (syncDBRecords *SyncDBRecords) GetDBRecords() DBRecords

+ func (syncDBRecords *SyncDBRecords) GetTableRecords(db string) TableRecords

+ func (syncDBRecords *SyncDBRecords) Reset()

+ func (syncDBRecords *SyncDBRecords) SetTableRecords(db string, tableRecords TableRecords)

v1.5.0

Jun 11, 2018

Changes in this version

+ const COUNT

+ const DATABASE

+ const DAY

+ const DefaultDoneRecordsFile

+ const DefaultMsSQLTable

+ const DefaultMySQLDatabase

+ const DefaultMySQLTable

+ const DefaultPGSQLTable

+ const HOUR

+ const MINUTE

+ const MONTH

+ const SECOND

+ const SQL_SPLITER

+ const SupportReminder

+ const TABLE

+ const Wildcards

+ const YEAR

+ var MysqlSystemDB = []string

+ func NewReader(meta *reader.Meta, conf conf.MapConf) (ret reader.Reader, err error)

+ func WriteRecordsFile(doneFilePath, content string) (err error)

+ type DBRecords map[string]TableRecords

+ func (dbRecords *DBRecords) GetTableRecords(db string) TableRecords

+ func (dbRecords *DBRecords) Reset()

+ func (dbRecords *DBRecords) Set(value DBRecords)

+ func (dbRecords *DBRecords) SetTableRecords(db string, tableRecords TableRecords)

+ type DataQuery struct

+ type Reader struct

+ Cron *cron.Cron

+ CurrentCount int64

+ func (r *Reader) Close() (err error)

+ func (r *Reader) Lag() (rl *LagInfo, err error)

+ func (r *Reader) LoopRun()

+ func (r *Reader) Name() string

+ func (r *Reader) ReadData() (Data, int64, error)

+ func (r *Reader) ReadLine() (string, error)

+ func (r *Reader) SetMode(mode string, v interface{}) error

+ func (r *Reader) Source() string

+ func (r *Reader) Start()

+ func (r *Reader) Status() StatsInfo

+ func (r *Reader) SyncMeta()

+ type TableInfo struct

+ type TableRecords map[string]TableInfo

+ func (tableRecords *TableRecords) GetTableInfo(table string) TableInfo

+ func (tableRecords *TableRecords) Reset()

+ func (tableRecords *TableRecords) Set(value TableRecords)

+ func (tableRecords *TableRecords) SetTableInfo(table string, tableInfo TableInfo)

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