implementations

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2023 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.