pgqueryengine

Documentation

Index

• type PostgresQueryEngine
  • func InitPostgresQueryEngine() *PostgresQueryEngine
  • func (pgqe *PostgresQueryEngine) AddData(dbConn *models.DBConnection, schema string, name string, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) AddSingleDataModelColumn(dbConn *models.DBConnection, schema, name, columnName, dataType string, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) AddSingleDataModelIndex(dbConn *models.DBConnection, schema, name, indexName string, colNames []string, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) DeleteData(dbConn *models.DBConnection, schema string, name string, ctids []string, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) DeleteSingleDataModelColumn(dbConn *models.DBConnection, schema, name, columnName string, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) DeleteSingleDataModelIndex(dbConn *models.DBConnection, indexName string, config *queryconfig.QueryConfig) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) GetData(dbConn *models.DBConnection, schema string, name string, limit int, ...) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) GetDataModels(dbConn *models.DBConnection, config *queryconfig.QueryConfig) ([]map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) GetSingleDataModelFields(dbConn *models.DBConnection, schema string, name string, ...) ([]map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) GetSingleDataModelIndexes(dbConn *models.DBConnection, schema string, name string, ...) ([]map[string]interface{}, error)
  • func (pxEngine *PostgresQueryEngine) RemoveUnusedConnections()
  • func (pgqe *PostgresQueryEngine) RunQuery(dbConn *models.DBConnection, query string, config *queryconfig.QueryConfig) (map[string]interface{}, error)
  • func (pgqe *PostgresQueryEngine) TestConnection(dbConn *models.DBConnection, config *queryconfig.QueryConfig) bool
  • func (pgqe *PostgresQueryEngine) UpdateSingleData(dbConn *models.DBConnection, schema string, name string, ctid string, ...) (map[string]interface{}, error)

Types

type PostgresQueryEngine

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

func InitPostgresQueryEngine

func InitPostgresQueryEngine() *PostgresQueryEngine

func (*PostgresQueryEngine) AddData

func (pgqe *PostgresQueryEngine) AddData(dbConn *models.DBConnection, schema string, name string, data map[string]interface{}, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) AddSingleDataModelColumn

func (pgqe *PostgresQueryEngine) AddSingleDataModelColumn(dbConn *models.DBConnection, schema, name, columnName, dataType string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) AddSingleDataModelIndex

func (pgqe *PostgresQueryEngine) AddSingleDataModelIndex(dbConn *models.DBConnection, schema, name, indexName string, colNames []string, isUnique bool, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) DeleteData

func (pgqe *PostgresQueryEngine) DeleteData(dbConn *models.DBConnection, schema string, name string, ctids []string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) DeleteSingleDataModelColumn

func (pgqe *PostgresQueryEngine) DeleteSingleDataModelColumn(dbConn *models.DBConnection, schema, name, columnName string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) DeleteSingleDataModelIndex

func (pgqe *PostgresQueryEngine) DeleteSingleDataModelIndex(dbConn *models.DBConnection, indexName string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) GetData

func (pgqe *PostgresQueryEngine) GetData(dbConn *models.DBConnection, schema string, name string, limit int, offset int64, fetchCount bool, filter []string, sort []string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) GetDataModels

func (pgqe *PostgresQueryEngine) GetDataModels(dbConn *models.DBConnection, config *queryconfig.QueryConfig) ([]map[string]interface{}, error)

func (*PostgresQueryEngine) GetSingleDataModelFields

func (pgqe *PostgresQueryEngine) GetSingleDataModelFields(dbConn *models.DBConnection, schema string, name string, config *queryconfig.QueryConfig) ([]map[string]interface{}, error)

func (*PostgresQueryEngine) GetSingleDataModelIndexes

func (pgqe *PostgresQueryEngine) GetSingleDataModelIndexes(dbConn *models.DBConnection, schema string, name string, config *queryconfig.QueryConfig) ([]map[string]interface{}, error)

func (*PostgresQueryEngine) RemoveUnusedConnections

func (pxEngine *PostgresQueryEngine) RemoveUnusedConnections()

func (*PostgresQueryEngine) RunQuery

func (pgqe *PostgresQueryEngine) RunQuery(dbConn *models.DBConnection, query string, config *queryconfig.QueryConfig) (map[string]interface{}, error)

func (*PostgresQueryEngine) TestConnection

func (pgqe *PostgresQueryEngine) TestConnection(dbConn *models.DBConnection, config *queryconfig.QueryConfig) bool

func (*PostgresQueryEngine) UpdateSingleData

func (pgqe *PostgresQueryEngine) UpdateSingleData(dbConn *models.DBConnection, schema string, name string, ctid string, columnName string, value string, config *queryconfig.QueryConfig) (map[string]interface{}, error)