database

Documentation

Index

• Variables
• func CloseOracleConnection(dbConnection *sql.DB) error
• func ConnectToMongo(host string) error
• func ConnectToOracle(connectionString string) (*sql.DB, error)
• func GetDB(session *mgo.Session, db string) *mgo.Database
• func GetSession() *mgo.Session
• func GetSessionAndDB(db string) (*mgo.Session, *mgo.Database)
• func InitDatabaseConnection() error
• func PageFromTo(page int, page_length int, arrayLen int) (int, int)
• func Query(q interface{}) error
• type MongoPool
  • func (mp *MongoPool) Close(session *mgo.Session)
  • func (mp *MongoPool) New() error
  • func (mp *MongoPool) Session() *mgo.Session

Variables

var IsConnectionDone = false

var MONGO_DB string

var MONGO_HOST string

var MONGO_PORT string

var ORACLE_CONNECTION_STRING string

var SD_TYPE = "file"

Functions

func CloseOracleConnection

func CloseOracleConnection(dbConnection *sql.DB) error

func ConnectToMongo

func ConnectToMongo(host string) error

func ConnectToOracle

func ConnectToOracle(connectionString string) (*sql.DB, error)

func GetDB

func GetDB(session *mgo.Session, db string) *mgo.Database

func GetSession

func GetSession() *mgo.Session

func GetSessionAndDB

func GetSessionAndDB(db string) (*mgo.Session, *mgo.Database)

func InitDatabaseConnection

func InitDatabaseConnection() error

func PageFromTo

func PageFromTo(page int, page_length int, arrayLen int) (int, int)

func Query

func Query(q interface{}) error

Types

type MongoPool

type MongoPool struct {
	BaseSession *mgo.Session
	Queue       chan int
	URL         string
	Open        int
}

var MongoDBPool MongoPool

func (*MongoPool) Close

func (mp *MongoPool) Close(session *mgo.Session)

func (*MongoPool) New

func (mp *MongoPool) New() error

func (*MongoPool) Session

func (mp *MongoPool) Session() *mgo.Session