mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
d1c9760fa8
* add postgresql datasource * add rest of files for postgres datasource * fix timeseries query, remove unused code * consistent naming, refactoring * s/mysql/postgres/ * s/mysql/postgres/ * couple more tests * tests for more datatypes * fix macros for postgres * add __timeSec macro * add frontend for postgres datasource * adjust documentation * fix formatting * add proper plugin description * merge editor changes from mysql * port changes from mysql datasource * set proper defaultQuery for postgres * add time_sec to timeseries query accept int for value for timeseries query * revert allowing time_sec and handle int or float values as unix timestamp for "time" column * fix tslint error * handle decimal values in timeseries query * allow setting sslmode for postgres datasource * use type switch for handling data types * fix value for timeseries query * refactor timeseries queries to make them more flexible * remove debug statement from inner loop in type conversion * use plain for loop in getTypedRowData * fix timeseries queries * adjust postgres datasource to tsdb refactoring * adjust postgres datasource to frontend changes * update lib/pq to latest version * move type conversion to getTypedRowData * handle address types cidr, inet and macaddr * adjust response parser and docs for annotations * convert unknown types to string * add documentation for postgres datasource * add another example query with metric column * set more helpful default query * update help text in query editor * handle NULL in value column of timeseries query * add __timeGroup macro * add test for __timeGroup macro * document __timeGroup and set proper default query for annotations * fix typos in docs * add postgres to list of datasources * add postgres to builtInPlugins * mysql: refactoring as prep for merging postgres Refactors out the initialization of the xorm engine and the query logic for an sql data source. * mysql: rename refactoring + test update * postgres:refactor to use SqlEngine(same as mysql) Refactored to use a common base class with the MySql data source. Other changes from the original PR: - Changed time column to be time_sec to allow other time units in the future and to be the same as MySQL - Changed integration test to test the main Query method rather than the private transformToTable method - Changed the __timeSec macro name to __timeEpoch - Renamed PostgresExecutor to PostgresQueryEndpoint Fixes #9209 (the original PR) * postgres: encrypt password on config page With some other cosmetic changes to the config page: - placeholder texts - reset button for the password after it has been encrypted. - default value for the sslmode field. * postgres: change back col name to time from time_sec * postgres mysql: remove annotation title Title has been removed from annotations * postgres: fix images for docs page * postgres mysql: fix specs
94 lines
2.4 KiB
Go
94 lines
2.4 KiB
Go
package pq
|
|
|
|
import (
|
|
"math"
|
|
"reflect"
|
|
"time"
|
|
|
|
"github.com/lib/pq/oid"
|
|
)
|
|
|
|
const headerSize = 4
|
|
|
|
type fieldDesc struct {
|
|
// The object ID of the data type.
|
|
OID oid.Oid
|
|
// The data type size (see pg_type.typlen).
|
|
// Note that negative values denote variable-width types.
|
|
Len int
|
|
// The type modifier (see pg_attribute.atttypmod).
|
|
// The meaning of the modifier is type-specific.
|
|
Mod int
|
|
}
|
|
|
|
func (fd fieldDesc) Type() reflect.Type {
|
|
switch fd.OID {
|
|
case oid.T_int8:
|
|
return reflect.TypeOf(int64(0))
|
|
case oid.T_int4:
|
|
return reflect.TypeOf(int32(0))
|
|
case oid.T_int2:
|
|
return reflect.TypeOf(int16(0))
|
|
case oid.T_varchar, oid.T_text:
|
|
return reflect.TypeOf("")
|
|
case oid.T_bool:
|
|
return reflect.TypeOf(false)
|
|
case oid.T_date, oid.T_time, oid.T_timetz, oid.T_timestamp, oid.T_timestamptz:
|
|
return reflect.TypeOf(time.Time{})
|
|
case oid.T_bytea:
|
|
return reflect.TypeOf([]byte(nil))
|
|
default:
|
|
return reflect.TypeOf(new(interface{})).Elem()
|
|
}
|
|
}
|
|
|
|
func (fd fieldDesc) Name() string {
|
|
return oid.TypeName[fd.OID]
|
|
}
|
|
|
|
func (fd fieldDesc) Length() (length int64, ok bool) {
|
|
switch fd.OID {
|
|
case oid.T_text, oid.T_bytea:
|
|
return math.MaxInt64, true
|
|
case oid.T_varchar, oid.T_bpchar:
|
|
return int64(fd.Mod - headerSize), true
|
|
default:
|
|
return 0, false
|
|
}
|
|
}
|
|
|
|
func (fd fieldDesc) PrecisionScale() (precision, scale int64, ok bool) {
|
|
switch fd.OID {
|
|
case oid.T_numeric, oid.T__numeric:
|
|
mod := fd.Mod - headerSize
|
|
precision = int64((mod >> 16) & 0xffff)
|
|
scale = int64(mod & 0xffff)
|
|
return precision, scale, true
|
|
default:
|
|
return 0, 0, false
|
|
}
|
|
}
|
|
|
|
// ColumnTypeScanType returns the value type that can be used to scan types into.
|
|
func (rs *rows) ColumnTypeScanType(index int) reflect.Type {
|
|
return rs.colTyps[index].Type()
|
|
}
|
|
|
|
// ColumnTypeDatabaseTypeName return the database system type name.
|
|
func (rs *rows) ColumnTypeDatabaseTypeName(index int) string {
|
|
return rs.colTyps[index].Name()
|
|
}
|
|
|
|
// ColumnTypeLength returns the length of the column type if the column is a
|
|
// variable length type. If the column is not a variable length type ok
|
|
// should return false.
|
|
func (rs *rows) ColumnTypeLength(index int) (length int64, ok bool) {
|
|
return rs.colTyps[index].Length()
|
|
}
|
|
|
|
// ColumnTypePrecisionScale should return the precision and scale for decimal
|
|
// types. If not applicable, ok should be false.
|
|
func (rs *rows) ColumnTypePrecisionScale(index int) (precision, scale int64, ok bool) {
|
|
return rs.colTyps[index].PrecisionScale()
|
|
}
|