Function connectDatabase

api/handler/v2/database.go:308–349

(reqParam *models.ConnectionReqV2)

}

func connectDatabase(reqParam *models.ConnectionReqV2) error {
	var db *gosql.DB
	var err error
	switch reqParam.DatabaseType {
	case DB_TYPE_MYSQL:
		uri, err := buildMysqlUri(reqParam.Host, reqParam.User, reqParam.Password,
			"", int(reqParam.Port), reqParam.IsPasswordEncrypted)
		if err != nil {
			return fmt.Errorf("build database Uri failed: %v", err)
		}
		db, err = sql.CreateDB(uri)
	case DB_TYPE_ORACLE:
		if reqParam.IsPasswordEncrypted && reqParam.Password != "" {
			realPwd, err := handler.DecryptPassword(reqParam.Password, g.RsaPrivateKey)
			if nil != err {
				return err
			}
			reqParam.Password = realPwd
		}
		db, err = config.OpenDb(&config.OracleConfig{
			User:        reqParam.User,
			Password:    reqParam.Password,
			Host:        reqParam.Host,
			Port:        reqParam.Port,
			ServiceName: reqParam.ServiceName,
		})
	default:
		return fmt.Errorf("data type %v is unsupport", reqParam.DatabaseType)
	}

	if err != nil {
		return fmt.Errorf("open db failed: %v", err)
	}
	defer db.Close()

	err = db.Ping()
	if err != nil {
		return err
	}

	return nil
}