func (m *Connection) Connect() (err error) {
	defer func() {
		if r := recover(); r != nil {
			// panic(r)
			// return
			if e, ok := r.(error); ok {
				err = e
			} else if e, ok := r.(string); ok {
				err = errors.New(e)
			} else {
				err = errors.New(fmt.Sprint(r))
			}

		}
	}()

	if m.Config.DialInfo == nil {
		if m.Config.DialInfo, err = mgo.ParseURL(m.Config.ConnectionString); err != nil {
			panic(fmt.Sprintf("cannot parse given URI %s due to error: %s", m.Config.ConnectionString, err.Error()))
		}
	}

	session, err := mgo.DialWithInfo(m.Config.DialInfo)
	if err != nil {
		return err
	}

	m.Session = session

	m.Session.SetMode(mgo.Monotonic, true)

	return nil
}
func (m *Connection) Connect() (err error) {
	defer func() {
		if r := recover(); r != nil {
			
			
			if e, ok := r.(error); ok {
				err = e
			} else if e, ok := r.(string); ok {
				err = errors.New(e)
			} else {
				err = errors.New(fmt.Sprint(r))
			}

		}
	}()

	if m.Config.DialInfo == nil {
		if m.Config.DialInfo, err = mgo.ParseURL(m.Config.ConnectionString); err != nil {
			panic(fmt.Sprintf("cannot parse given URI %s due to error: %s", m.Config.ConnectionString, err.Error()))
		}
	}

	session, err := mgo.DialWithInfo(m.Config.DialInfo)
	if err != nil {
		return err
	}

	m.Session = session

	m.Session.SetMode(mgo.Monotonic, true)

	return nil
}
func ( m * Connection ) Connect ( ) ( err error ) { defer func ( ) { if r := recover ( ) ; r != nil { // panic(r) // return if e , ok := r . ( error ) ; ok { err = e } else if e , ok := r . ( string ) ; ok { err = errors . New ( e ) } else { err = errors . New ( fmt . Sprint ( r ) ) } } } ( ) if m . Config . DialInfo == nil { if m . Config . DialInfo , err = mgo . ParseURL ( m . Config . ConnectionString ) ; err != nil { panic ( fmt . Sprintf ( " " , m . Config . ConnectionString , err . Error ( ) ) ) } } session , err := mgo . DialWithInfo ( m . Config . DialInfo ) if err != nil { return err } m . Session = session m . Session . SetMode ( mgo . Monotonic , true ) return nil }
// Connect to the database using the provided config
Connect to the database using the provided config