Method QueryLog

datasource/postgresql/postgresql.go:218–261

(ctx context.Context, query interface{})

}

func (p *PostgreSQL) QueryLog(ctx context.Context, query interface{}) ([]interface{}, int64, error) {
	postgresqlQueryParam := new(QueryParam)
	if err := mapstructure.Decode(query, postgresqlQueryParam); err != nil {
		return nil, 0, err
	}
	if postgresqlQueryParam.Database != "" {
		p.Shards[0].DB = postgresqlQueryParam.Database
	} else {
		db, err := parseDBName(postgresqlQueryParam.SQL)
		if err != nil {
			return nil, 0, err
		}
		p.Shards[0].DB = db
	}

	postgresqlQueryParam.SQL = formatSQLDatabaseNameWithRegex(postgresqlQueryParam.SQL)
	if strings.Contains(postgresqlQueryParam.SQL, "$__") {
		var err error
		postgresqlQueryParam.SQL, err = macros.Macro(postgresqlQueryParam.SQL, postgresqlQueryParam.From, postgresqlQueryParam.To)
		if err != nil {
			return nil, 0, err
		}
	}

	timeout := p.Shards[0].Timeout
	if timeout == 0 {
		timeout = 60
	}
	timeoutCtx, cancel := context.WithTimeout(ctx, time.Duration(timeout)*time.Second)
	defer cancel()
	items, err := p.Shards[0].Query(timeoutCtx, &sqlbase.QueryParam{
		Sql: postgresqlQueryParam.SQL,
	})
	if err != nil {
		logger.Warningf("query:%+v get data err:%v", postgresqlQueryParam, err)
		return []interface{}{}, 0, err
	}
	logs := make([]interface{}, 0)
	for i := range items {
		logs = append(logs, items[i])
	}

	return logs, 0, nil
}

func (p *PostgreSQL) DescribeTable(ctx context.Context, query interface{}) ([]*types.ColumnProperty, error) {
	postgresqlQueryParam := new(QueryParam)