udwSqlite3

Documentation

Index

• Constants
• func IsErrorDatabaseCorrupt(errMsg string) bool
• func MustDeleteSqliteDbFileByPath(path string)
• func MustGetSqlite3Version() string
• type Db
  • func MustNewDb(req NewDbRequest) *Db
  • func MustNewMemoryDb() *Db
  • func (db *Db) Close()
  • func (db *Db) Get(k1 string, k2 string) (value string, err error)
  • func (db *Db) IMustDelete(k1 string, k2 string)
  • func (db *Db) MustCountGetRange(req GetRangeReq) int
  • func (db *Db) MustDelete(k1 string, k2 string)
  • func (db *Db) MustDeleteK1(k1 string)
  • func (db *Db) MustDeleteWithKv(k1 string, k2 string, v string)
  • func (db *Db) MustEmptyDatabase()
  • func (db *Db) MustEmptyK1(k1 string)
  • func (db *Db) MustExist(k1 string, k2 string) bool
  • func (db *Db) MustGet(k1 string, k2 string) string
  • func (db *Db) MustGetAllDataInTableToRowMap(tableName string) []map[string]string
  • func (db *Db) MustGetAllK1() []string
  • func (db *Db) MustGetInt64(k1 string, k2 string) int64
  • func (db *Db) MustGetRange(req GetRangeReq) []udwMap.KeyValuePair
  • func (db *Db) MustGetRangeCallback(req GetRangeReq, visitor func(key string, value string))
  • func (db *Db) MustGetRangeKeyList(req GetRangeReq) []string
  • func (db *Db) MustGetRangeKeyListCallback(req GetRangeReq, visitor func(key string))
  • func (db *Db) MustGetRangeKeyMap(req GetRangeReq) map[string]struct{}
  • func (db *Db) MustGetRangeToMap(req GetRangeReq) map[string]string
  • func (db *Db) MustGetRangeValueList(req GetRangeReq) []string
  • func (db *Db) MustGetTableNameList() []string
  • func (db *Db) MustInsert(k1 string, k2 string, value string)
  • func (db *Db) MustInsertAndReturnHasSucc(k1 string, k2 string, value string) bool
  • func (db *Db) MustMulitDelete(k1 string, k2List []string)
  • func (db *Db) MustMulitExist(k1 string, k2List []string) (output map[string]struct{})
  • func (db *Db) MustMulitGet(k1 string, k2List []string) (output []udwMap.KeyValuePair)
  • func (db *Db) MustMulitSet(k1 string, pairList []udwMap.KeyValuePair)
  • func (db *Db) MustMulitSetByKeySet(k1 string, keySet map[string]struct{})
  • func (db *Db) MustMulitSetMap(k1 string, m map[string]string)
  • func (db *Db) MustQuery(req QueryReq)
  • func (db *Db) MustSet(k1 string, k2 string, value string)
  • func (db *Db) MustSetInt64(k1 string, k2 string, v int64)
  • func (db *Db) MustTableCopy(fromK1Name string, toK1Name string)
  • func (db *Db) MustUpdate(k1 string, k2 string, value string)
  • func (db *Db) NewMsb(threadNum int) *Msb
  • func (c *Db) Query(req QueryReq) (errMsg string)
  • func (db *Db) Set(k1 string, k2 string, value string) (errMsg string)
• type GetRangeReq
• type Msb
  • func (msc *Msb) MustClose()
  • func (msc *Msb) MustFlush()
  • func (msc *Msb) Set(k1 string, k2 string, v string)
• type NewDbRequest
• type QueryReq
• type QueryRespStatus

Constants

const JournalModeDELETE = "DELETE"

const JournalModeOFF = "OFF"

const JournalModeWAL = "WAL"

const SynchronousFULL = "FULL"

const SynchronousNORMAL = "NORMAL"

const SynchronousOFF = "OFF"

Functions

func IsErrorDatabaseCorrupt

func IsErrorDatabaseCorrupt(errMsg string) bool

func MustDeleteSqliteDbFileByPath

func MustDeleteSqliteDbFileByPath(path string)

func MustGetSqlite3Version

func MustGetSqlite3Version() string

Types

type Db

type Db struct {
	// contains filtered or unexported fields
}

func MustNewDb

func MustNewDb(req NewDbRequest) *Db

func MustNewMemoryDb

func MustNewMemoryDb() *Db

func (*Db) Close

func (db *Db) Close()

func (*Db) Get

func (db *Db) Get(k1 string, k2 string) (value string, err error)

func (*Db) IMustDelete

func (db *Db) IMustDelete(k1 string, k2 string)

func (*Db) MustCountGetRange

func (db *Db) MustCountGetRange(req GetRangeReq) int

func (*Db) MustDelete

func (db *Db) MustDelete(k1 string, k2 string)

func (*Db) MustDeleteK1

func (db *Db) MustDeleteK1(k1 string)

func (*Db) MustDeleteWithKv

func (db *Db) MustDeleteWithKv(k1 string, k2 string, v string)

func (*Db) MustEmptyDatabase

func (db *Db) MustEmptyDatabase()

func (*Db) MustEmptyK1

func (db *Db) MustEmptyK1(k1 string)

func (*Db) MustExist

func (db *Db) MustExist(k1 string, k2 string) bool

func (*Db) MustGet

func (db *Db) MustGet(k1 string, k2 string) string

func (*Db) MustGetAllDataInTableToRowMap

func (db *Db) MustGetAllDataInTableToRowMap(tableName string) []map[string]string

func (*Db) MustGetAllK1

func (db *Db) MustGetAllK1() []string

func (*Db) MustGetInt64

func (db *Db) MustGetInt64(k1 string, k2 string) int64

func (*Db) MustGetRange

func (db *Db) MustGetRange(req GetRangeReq) []udwMap.KeyValuePair

func (*Db) MustGetRangeCallback

func (db *Db) MustGetRangeCallback(req GetRangeReq, visitor func(key string, value string))

func (*Db) MustGetRangeKeyList

func (db *Db) MustGetRangeKeyList(req GetRangeReq) []string

func (*Db) MustGetRangeKeyListCallback

func (db *Db) MustGetRangeKeyListCallback(req GetRangeReq, visitor func(key string))

func (*Db) MustGetRangeKeyMap

func (db *Db) MustGetRangeKeyMap(req GetRangeReq) map[string]struct{}

func (*Db) MustGetRangeToMap

func (db *Db) MustGetRangeToMap(req GetRangeReq) map[string]string

func (*Db) MustGetRangeValueList

func (db *Db) MustGetRangeValueList(req GetRangeReq) []string

func (*Db) MustGetTableNameList

func (db *Db) MustGetTableNameList() []string

func (*Db) MustInsert

func (db *Db) MustInsert(k1 string, k2 string, value string)

func (*Db) MustInsertAndReturnHasSucc

func (db *Db) MustInsertAndReturnHasSucc(k1 string, k2 string, value string) bool

func (*Db) MustMulitDelete

func (db *Db) MustMulitDelete(k1 string, k2List []string)

func (*Db) MustMulitExist

func (db *Db) MustMulitExist(k1 string, k2List []string) (output map[string]struct{})

func (*Db) MustMulitGet

func (db *Db) MustMulitGet(k1 string, k2List []string) (output []udwMap.KeyValuePair)

func (*Db) MustMulitSet

func (db *Db) MustMulitSet(k1 string, pairList []udwMap.KeyValuePair)

func (*Db) MustMulitSetByKeySet

func (db *Db) MustMulitSetByKeySet(k1 string, keySet map[string]struct{})

func (*Db) MustMulitSetMap

func (db *Db) MustMulitSetMap(k1 string, m map[string]string)

func (*Db) MustQuery

func (db *Db) MustQuery(req QueryReq)

func (*Db) MustSet

func (db *Db) MustSet(k1 string, k2 string, value string)

func (*Db) MustSetInt64

func (db *Db) MustSetInt64(k1 string, k2 string, v int64)

func (*Db) MustTableCopy

func (db *Db) MustTableCopy(fromK1Name string, toK1Name string)

func (*Db) MustUpdate

func (db *Db) MustUpdate(k1 string, k2 string, value string)

func (*Db) NewMsb

func (db *Db) NewMsb(threadNum int) *Msb

func (*Db) Query

func (c *Db) Query(req QueryReq) (errMsg string)

func (*Db) Set

func (db *Db) Set(k1 string, k2 string, value string) (errMsg string)

type GetRangeReq

type GetRangeReq struct {
	K1                 string
	IsDescOrder        bool
	MinValue           string
	MaxValue           string
	MinValueNotInclude string
	MaxValueNotInclude string
	Prefix             string
	Limit              int
}

type Msb

type Msb struct {
	// contains filtered or unexported fields
}

func (*Msb) MustClose

func (msc *Msb) MustClose()

func (*Msb) MustFlush

func (msc *Msb) MustFlush()

func (*Msb) Set

func (msc *Msb) Set(k1 string, k2 string, v string)

type NewDbRequest

type NewDbRequest struct {
	FilePath string

	EmptyDatabaseIfDatabaseCorrupt bool

	UsingMemory bool

	JournalMode string

	Synchronous string

	DatabaseCorruptCallback func()

	EncryptPskString string

	MulitDeleteMaxSize int
}

type QueryReq

type QueryReq struct {
	Query        string
	Args         [][]byte
	ColumnsCb    func(columnNameList [][]byte)
	RespStatusCb func(status QueryRespStatus)
	RespDataCb   func(result [][]byte)
	ColumnCount  int
	UseStmtCache bool
}

type QueryRespStatus

type QueryRespStatus struct {
	AffectedRows uint64
	LastInsertId uint64
}