Nanosecond timestamp support postgresql

This commit is contained in:
Ander Arguiñano
2019-01-02 23:00:21 +01:00
parent a7d4e6caa3
commit 1a67a8db80
2 changed files with 23 additions and 0 deletions

View File

@ -115,6 +115,12 @@ func TestMacroEngine(t *testing.T) {
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.Unix(), to.Unix()))
})
Convey("interpolate __unixEpochFilterNano function", func() {
sql, err := engine.Interpolate(query, timeRange, "select $__unixEpochFilterNano(time)")
So(err, ShouldBeNil)
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.UnixNano(), to.UnixNano()))
})
Convey("interpolate __unixEpochGroup function", func() {
@ -147,6 +153,12 @@ func TestMacroEngine(t *testing.T) {
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.Unix(), to.Unix()))
})
Convey("interpolate __unixEpochFilterNano function", func() {
sql, err := engine.Interpolate(query, timeRange, "select $__unixEpochFilterNano(time)")
So(err, ShouldBeNil)
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.UnixNano(), to.UnixNano()))
})
})
Convey("Given a time range between 1960-02-01 07:00 and 1980-02-03 08:00", func() {
@ -167,6 +179,12 @@ func TestMacroEngine(t *testing.T) {
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.Unix(), to.Unix()))
})
Convey("interpolate __unixEpochFilterNano function", func() {
sql, err := engine.Interpolate(query, timeRange, "select $__unixEpochFilterNano(time)")
So(err, ShouldBeNil)
So(sql, ShouldEqual, fmt.Sprintf("select time >= %d AND time <= %d", from.UnixNano(), to.UnixNano()))
})
})
})
}