implementations

Documentation

Index

• type DBCommon
  • func (dbc *DBCommon) ChangeDatabase(dbName string) error
  • func (dbc *DBCommon) SetCache(cache *caches.Cache)
• type MongoConnection
  • func (mc *MongoConnection) Connect(uri string) error
  • func (mc *MongoConnection) ConnectWithCertificate(uri string, filePath string) error
  • func (mc *MongoConnection) CreateMany([]interface{})
  • func (mc *MongoConnection) CreateTable(ifNotExist bool)
  • func (mc *MongoConnection) DeleteMany(qmap ftypes.QMap)
  • func (mc *MongoConnection) DeleteOne(sliceData ...interface{}) error
  • func (mc *MongoConnection) DisConnect() error
  • func (mc *MongoConnection) FindMany(interface{})
  • func (mc *MongoConnection) FindOne(result interface{}, dbFusionOptions ...queryoptions.FindOptions) error
  • func (mc *MongoConnection) InsertOne(data interface{}) error
  • func (mc *MongoConnection) Limit(limit int64) connections.MongoConnection
  • func (mc *MongoConnection) Paginate(interface{}, ...queryoptions.FindOptions)
  • func (mc *MongoConnection) Project(keys map[string]bool) connections.MongoConnection
  • func (mc *MongoConnection) RegisterSchema()
  • func (mc *MongoConnection) Skip(skip int64) connections.MongoConnection
  • func (mc *MongoConnection) Sort(sortKey string, sortdesc ...bool) connections.MongoConnection
  • func (mc *MongoConnection) Table(tablename string) connections.MongoConnection
  • func (mc *MongoConnection) UpdateAndFindOne(data interface{}, result interface{}, upsert bool) error
  • func (mc *MongoConnection) UpdateMany([]interface{})
  • func (mc *MongoConnection) Where(query interface{}) connections.MongoConnection
• type MySql
  • func (ms *MySql) Connect(uri string) error
  • func (ms *MySql) ConnectWithCertificate(uri string, filePath string) error
  • func (ms *MySql) CreateMany([]interface{})
  • func (ms *MySql) CreateTable(ifNotExist bool)
  • func (ms *MySql) DeleteMany(qmap ftypes.QMap)
  • func (ms *MySql) DeleteOne(sliceData ...interface{}) error
  • func (ms *MySql) DisConnect() error
  • func (ms *MySql) ExecuteSQL(sql string, args ...interface{}) error
  • func (mc *MySql) FindMany(interface{})
  • func (ms *MySql) FindOne(result interface{}, dbFusionOptions ...queryoptions.FindOptions) error
  • func (ms *MySql) GroupBy(fieldName string) connections.SQLConnection
  • func (ms *MySql) Having(data interface{}) connections.SQLConnection
  • func (ms *MySql) InsertOne(data interface{}) error
  • func (ms *MySql) Join(join joins.Join) connections.SQLConnection
  • func (ms *MySql) Limit(limit int64) connections.SQLConnection
  • func (ms *MySql) Paginate(interface{}, ...queryoptions.FindOptions)
  • func (ms *MySql) Project(keys map[string]bool) connections.SQLConnection
  • func (ms *MySql) RegisterSchema()
  • func (ms *MySql) Skip(skip int64) connections.SQLConnection
  • func (ms *MySql) Sort(sortKey string, sortdesc ...bool) connections.SQLConnection
  • func (ms *MySql) Table(tablename string) connections.SQLConnection
  • func (ms *MySql) UpdateAndFindOne(data interface{}, result interface{}, upsert bool) error
  • func (ms *MySql) UpdateMany([]interface{})
  • func (ms *MySql) Where(query interface{}) connections.SQLConnection
• type SqlBase

Types

type DBCommon

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

func (*DBCommon) ChangeDatabase

func (dbc *DBCommon) ChangeDatabase(dbName string) error

func (*DBCommon) SetCache

func (dbc *DBCommon) SetCache(cache *caches.Cache)

type MongoConnection

type MongoConnection struct {
	DBCommon
	// contains filtered or unexported fields
}

func (*MongoConnection) Connect

func (mc *MongoConnection) Connect(uri string) error

func (*MongoConnection) ConnectWithCertificate

func (mc *MongoConnection) ConnectWithCertificate(uri string, filePath string) error

TODO: add the communication with certificate TODO: add the options for cache enabling and disabling TODO: add thhe

func (*MongoConnection) CreateMany

func (mc *MongoConnection) CreateMany([]interface{})

New methods for bulk operations.

func (*MongoConnection) CreateTable

func (mc *MongoConnection) CreateTable(ifNotExist bool)

func (*MongoConnection) DeleteMany

func (mc *MongoConnection) DeleteMany(qmap ftypes.QMap)

func (*MongoConnection) DeleteOne

func (mc *MongoConnection) DeleteOne(sliceData ...interface{}) error

func (*MongoConnection) DisConnect

func (mc *MongoConnection) DisConnect() error

func (*MongoConnection) FindMany

func (mc *MongoConnection) FindMany(interface{})

func (*MongoConnection) FindOne

func (mc *MongoConnection) FindOne(result interface{}, dbFusionOptions ...queryoptions.FindOptions) error

func (*MongoConnection) InsertOne

func (mc *MongoConnection) InsertOne(data interface{}) error

func (*MongoConnection) Limit

func (mc *MongoConnection) Limit(limit int64) connections.MongoConnection

func (*MongoConnection) Paginate

func (mc *MongoConnection) Paginate(interface{}, ...queryoptions.FindOptions)

func (*MongoConnection) Project

func (mc *MongoConnection) Project(keys map[string]bool) connections.MongoConnection

func (*MongoConnection) RegisterSchema

func (mc *MongoConnection) RegisterSchema()

func (*MongoConnection) Skip

func (mc *MongoConnection) Skip(skip int64) connections.MongoConnection

func (*MongoConnection) Sort

func (mc *MongoConnection) Sort(sortKey string, sortdesc ...bool) connections.MongoConnection

func (*MongoConnection) Table

func (mc *MongoConnection) Table(tablename string) connections.MongoConnection

func (*MongoConnection) UpdateAndFindOne

func (mc *MongoConnection) UpdateAndFindOne(data interface{}, result interface{}, upsert bool) error

func (*MongoConnection) UpdateMany

func (mc *MongoConnection) UpdateMany([]interface{})

func (*MongoConnection) Where

func (mc *MongoConnection) Where(query interface{}) connections.MongoConnection

type MySql

type MySql struct {
	SqlBase
	// contains filtered or unexported fields
}

func (*MySql) Connect

func (ms *MySql) Connect(uri string) error

func (*MySql) ConnectWithCertificate

func (ms *MySql) ConnectWithCertificate(uri string, filePath string) error

TODO: add the communication with certificate TODO: add the options for cache enabling and disabling TODO: add thhe

func (*MySql) CreateMany

func (ms *MySql) CreateMany([]interface{})

New methods for bulk operations.

func (*MySql) CreateTable

func (ms *MySql) CreateTable(ifNotExist bool)

New method to create a table.

func (*MySql) DeleteMany

func (ms *MySql) DeleteMany(qmap ftypes.QMap)

func (*MySql) DeleteOne

func (ms *MySql) DeleteOne(sliceData ...interface{}) error

func (*MySql) DisConnect

func (ms *MySql) DisConnect() error

func (*MySql) ExecuteSQL

func (ms *MySql) ExecuteSQL(sql string, args ...interface{}) error

func (*MySql) FindMany

func (mc *MySql) FindMany(interface{})

func (*MySql) FindOne

func (ms *MySql) FindOne(result interface{}, dbFusionOptions ...queryoptions.FindOptions) error

func (*MySql) GroupBy

func (ms *MySql) GroupBy(fieldName string) connections.SQLConnection

func (*MySql) Having

func (ms *MySql) Having(data interface{}) connections.SQLConnection

func (*MySql) InsertOne

func (ms *MySql) InsertOne(data interface{}) error

func (*MySql) Join

func (ms *MySql) Join(join joins.Join) connections.SQLConnection

func (*MySql) Limit

func (ms *MySql) Limit(limit int64) connections.SQLConnection

func (*MySql) Paginate

func (ms *MySql) Paginate(interface{}, ...queryoptions.FindOptions)

func (*MySql) Project

func (ms *MySql) Project(keys map[string]bool) connections.SQLConnection

func (*MySql) RegisterSchema

func (ms *MySql) RegisterSchema()

func (*MySql) Skip

func (ms *MySql) Skip(skip int64) connections.SQLConnection

func (*MySql) Sort

func (ms *MySql) Sort(sortKey string, sortdesc ...bool) connections.SQLConnection

func (*MySql) Table

func (ms *MySql) Table(tablename string) connections.SQLConnection

func (*MySql) UpdateAndFindOne

func (ms *MySql) UpdateAndFindOne(data interface{}, result interface{}, upsert bool) error

func (*MySql) UpdateMany

func (ms *MySql) UpdateMany([]interface{})

func (*MySql) Where

func (ms *MySql) Where(query interface{}) connections.SQLConnection

type SqlBase

type SqlBase struct {
	DBCommon
}