mqlite

Documentation

Index

• Constants
• type MetaTableScheme
• type MetaTableSchemeDao
  • func NewTableSchemeDao(name string) *MetaTableSchemeDao
  • func (s *MetaTableSchemeDao) GoLevelGetTableNewAutoID(tableName string, client *mgolevel.GoLevelDriver) (id uint32)
  • func (s *MetaTableSchemeDao) GoLevelMeta_CreateTableSpace(tableName string, client *mgolevel.GoLevelDriver)
  • func (s *MetaTableSchemeDao) GoLevelMeta_GetTableKey(tableName string) (key string)
  • func (s *MetaTableSchemeDao) GoLevelUpdateAutoId(table string, client *mgolevel.GoLevelDriver)
  • func (s *MetaTableSchemeDao) GoLevel_tableIsExisted(tableName string, client *mgolevel.GoLevelDriver) (b bool)
  • func (s *MetaTableSchemeDao) GoLevelcheck_table_meta(tableName string, client *mgolevel.GoLevelDriver)
  • func (s *MetaTableSchemeDao) MongoGetTableNewAutoID(tableName string, client *mmongo.MongoNewDriver) (id uint32)
  • func (s *MetaTableSchemeDao) MongoMeta_CreateTableSpace(tableName string, client *mmongo.MongoNewDriver)
  • func (s *MetaTableSchemeDao) MongoMeta_GetTableKey(tableName string) (key string)
  • func (s *MetaTableSchemeDao) MongoUpdateAutoId(table string, client *mmongo.MongoNewDriver)
  • func (s *MetaTableSchemeDao) Mongo_tableIsExisted(tableName string, client *mmongo.MongoNewDriver) (b bool)
  • func (s *MetaTableSchemeDao) Mongocheck_table_meta(tableName string, client *mmongo.MongoNewDriver)
• type Mqlite
• type MqliteImpl
  • func NewClient(uri string, dbname string) *MqliteImpl
  • func (s *MqliteImpl) Connect(timeout time.Duration) (err error)
  • func (s *MqliteImpl) Count(table string) (count uint32, err error)
  • func (s *MqliteImpl) DeleteOne(table string, id uint32) (err error)
  • func (s *MqliteImpl) FindAll(table string, out interface{}) (err error)
  • func (s *MqliteImpl) FindOne(table string, id uint32, out interface{}) (err error)
  • func (s *MqliteImpl) GetKeyPrefix(tableName string) (key string)
  • func (s *MqliteImpl) Insert(table string, doc interface{}) (id uint32, err error)
  • func (s *MqliteImpl) UpdateOne(table string, id uint32, doc interface{}) (err error)

Constants

const (
	CNT_DataBaseName = "mqlitedb"
)

Types

type MetaTableScheme

type MetaTableScheme struct {
	TableName   string // 表名，最长64个字符
	AutoIncrSeq int    // 自动增长序列号，从1开始
	CreateTime  string // 创建时间
	UpdateTime  string // 更新时间
	DeleteTime  string // 删除时间
}

type MetaTableSchemeDao

type MetaTableSchemeDao struct {
	DbName    string // 数据库名称
	TableName string // 表名
}

表空间的结构

func NewTableSchemeDao

func NewTableSchemeDao(name string) *MetaTableSchemeDao

func (*MetaTableSchemeDao) GoLevelGetTableNewAutoID

func (s *MetaTableSchemeDao) GoLevelGetTableNewAutoID(tableName string, client *mgolevel.GoLevelDriver) (id uint32)

func (*MetaTableSchemeDao) GoLevelMeta_CreateTableSpace

func (s *MetaTableSchemeDao) GoLevelMeta_CreateTableSpace(tableName string, client *mgolevel.GoLevelDriver)

func (*MetaTableSchemeDao) GoLevelMeta_GetTableKey

func (s *MetaTableSchemeDao) GoLevelMeta_GetTableKey(tableName string) (key string)

func (*MetaTableSchemeDao) GoLevelUpdateAutoId

func (s *MetaTableSchemeDao) GoLevelUpdateAutoId(table string, client *mgolevel.GoLevelDriver)

func (*MetaTableSchemeDao) GoLevel_tableIsExisted

func (s *MetaTableSchemeDao) GoLevel_tableIsExisted(tableName string, client *mgolevel.GoLevelDriver) (b bool)

func (*MetaTableSchemeDao) GoLevelcheck_table_meta

func (s *MetaTableSchemeDao) GoLevelcheck_table_meta(tableName string, client *mgolevel.GoLevelDriver)

func (*MetaTableSchemeDao) MongoGetTableNewAutoID

func (s *MetaTableSchemeDao) MongoGetTableNewAutoID(tableName string, client *mmongo.MongoNewDriver) (id uint32)

func (*MetaTableSchemeDao) MongoMeta_CreateTableSpace

func (s *MetaTableSchemeDao) MongoMeta_CreateTableSpace(tableName string, client *mmongo.MongoNewDriver)

func (*MetaTableSchemeDao) MongoMeta_GetTableKey

func (s *MetaTableSchemeDao) MongoMeta_GetTableKey(tableName string) (key string)

func (*MetaTableSchemeDao) MongoUpdateAutoId

func (s *MetaTableSchemeDao) MongoUpdateAutoId(table string, client *mmongo.MongoNewDriver)

func (*MetaTableSchemeDao) Mongo_tableIsExisted

func (s *MetaTableSchemeDao) Mongo_tableIsExisted(tableName string, client *mmongo.MongoNewDriver) (b bool)

func (*MetaTableSchemeDao) Mongocheck_table_meta

func (s *MetaTableSchemeDao) Mongocheck_table_meta(tableName string, client *mmongo.MongoNewDriver)

type Mqlite

type Mqlite interface {
	Connect(timeout time.Duration) (err error)
	Insert(table string, doc interface{}) (id uint32, err error)
	FindOne(table string, id uint32, out interface{}) (err error)
	DeleteOne(table string, id uint32) (err error)
	Count(table string) (count uint32, err error)
	UpdateOne(table string, id uint32, doc interface{}) (err error)
	FindAll(table string, out interface{}) (err error)
}

var (
	DB Mqlite
)

type MqliteImpl

type MqliteImpl struct {
	StoreMode   int // 0 mongodb 1 golevel
	NoSqlClient nosql.NoSqlClient

	Uri    string
	Name   string
	DbName string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(uri string, dbname string) *MqliteImpl

func (*MqliteImpl) Connect

func (s *MqliteImpl) Connect(timeout time.Duration) (err error)

func (*MqliteImpl) Count

func (s *MqliteImpl) Count(table string) (count uint32, err error)

func (*MqliteImpl) DeleteOne

func (s *MqliteImpl) DeleteOne(table string, id uint32) (err error)

func (*MqliteImpl) FindAll

func (s *MqliteImpl) FindAll(table string, out interface{}) (err error)

func (*MqliteImpl) FindOne

func (s *MqliteImpl) FindOne(table string, id uint32, out interface{}) (err error)

func (*MqliteImpl) GetKeyPrefix

func (s *MqliteImpl) GetKeyPrefix(tableName string) (key string)

func (*MqliteImpl) Insert

func (s *MqliteImpl) Insert(table string, doc interface{}) (id uint32, err error)

func (*MqliteImpl) UpdateOne

func (s *MqliteImpl) UpdateOne(table string, id uint32, doc interface{}) (err error)