diff --git a/server/pg.go b/server/pg.go index 230541b87..70ecdb074 100644 --- a/server/pg.go +++ b/server/pg.go @@ -418,6 +418,14 @@ func pgWriteStmtRows(w pg.QueryResultWriter, rows *pilosa.StmtRows) error { } return nil } +func getPgTypeFromColumnInfo(sql2type string) pg.Type { + ret := pg.TypeCharoid + switch sql2type { + case sql2.DataTypeInt: + ret = pg.TypeINT4OID + } + return ret +} func pgWriteRowser(w pg.QueryResultWriter, result pb.ToRowser) error { var data []string @@ -427,7 +435,8 @@ func pgWriteRowser(w pg.QueryResultWriter, result pb.ToRowser) error { for i, h := range row.Headers { headers[i] = pg.ColumnInfo{ Name: h.Name, - Type: pg.TypeCharoid, + Type: pg.TypeCharoid, // TODO(twg) this needs to be updated with type + // information so it works from psql client } } err := w.WriteHeader(headers...) diff --git a/storage/config.go b/storage/config.go index e578ab9b9..05882db04 100644 --- a/storage/config.go +++ b/storage/config.go @@ -37,6 +37,6 @@ type Config struct { func NewDefaultConfig() *Config { return &Config{ Backend: DefaultBackend, - FsyncEnabled: true, + FsyncEnabled: false, } }