Gleipnir/jet
4
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Pre-release clean up.

Browse source
This commit is contained in:
go-jet 2019-07-17 13:22:14 +02:00
parent 23a27033a4
commit b817f57035
27 changed files with 628 additions and 79 deletions
Download patch file Download diff file Expand all files Collapse all files

13
execution/execution.go
View file

@ -36,8 +36,6 @@ func Query(db DB, context context.Context, query string, args []interface{}, des
return err
}
fmt.Println("TEMP SLICE SIZE: ", tempSliceValue.Len())
if tempSliceValue.Len() == 0 {
return nil
}
@ -89,8 +87,6 @@ func queryToSlice(db DB, ctx context.Context, query string, args []interface{},
return nil
}
groupTime := time.Duration(0)
slicePtrValue := reflect.ValueOf(slicePtr)
for rows.Next() {
@ -102,19 +98,13 @@ func queryToSlice(db DB, ctx context.Context, query string, args []interface{},
scanContext.rowNum++
begin := time.Now()
_, err = mapRowToSlice(scanContext, "", slicePtrValue, nil)
if err != nil {
return err
}
groupTime += time.Now().Sub(begin)
}
fmt.Println(groupTime.String())
err = rows.Close()
if err != nil {
return err
@ -126,8 +116,6 @@ func queryToSlice(db DB, ctx context.Context, query string, args []interface{},
return err
}
fmt.Println(strconv.Itoa(scanContext.rowNum) + " ROW(S) PROCESSED")
return nil
}
@ -596,7 +584,6 @@ func newScanType(columnType *sql.ColumnType) reflect.Type {
case "DATE", "TIMESTAMP", "TIMESTAMPTZ", "TIME", "TIMETZ":
return nullTimeType
default:
fmt.Println("Unknown column database type " + columnType.DatabaseTypeName() + " using string as default.")
return nullStringType
}
}