123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130 |
- package xugu
- import (
- "database/sql/driver"
- "encoding/binary"
- "errors"
- "fmt"
- "reflect"
- )
- type xuguRows struct {
-
-
-
- results *SelectResult
-
- lastRowRelt int
-
- lastRelt int
-
-
- prepared bool
-
- rows_conn *xuguConn
-
- }
- func (row *xuguRows) Next(dest []driver.Value) error {
- fmt.Println(">>>>>(self *xuguRows) Next() ")
- if row.results.rowIdx >= len(row.results.Values[0]) {
- return errors.New("The result set has been released")
- }
-
- for j := 0; j < int(row.results.Field_Num); j++ {
- coluType := row.results.Fields[j].FieldType
-
- switch coluType {
- case fieldType_DATE:
- case fieldType_BINARY,
- fieldType_CLOB, fieldType_BLOB:
- case fieldType_TIME,
- fieldType_TIME_TZ:
- case fieldType_DATETIME,
- fieldType_DATETIME_TZ:
- case fieldType_I1:
- dest[j] = int8(row.results.Values[j][row.results.rowIdx].Col_Data[0])
- case fieldType_I4:
- dest[j] = binary.LittleEndian.Uint32(row.results.Values[j][row.results.rowIdx].Col_Data)
- default:
-
-
- dest[j] = make([]byte, len(row.results.Values))
-
- dest[j] = row.results.Values[j][row.results.rowIdx].Col_Data
- }
- }
- row.results.rowIdx++
- return nil
- }
- func (row *xuguRows) Columns() []string {
- fmt.Println(">>>>>(self *xuguRows) Columns() ")
-
-
-
-
-
-
-
- var columns []string
- for i, v := range row.results.Fields {
- columns = append(columns, v.FieldName)
- fmt.Printf("append(columns, v.FieldName) 个数%d ,%s", i+1, columns[i])
- }
-
-
-
-
- return columns
- }
- func (row *xuguRows) ColumnTypeScanType(index int) reflect.Type {
- fmt.Println(">>>>>ColumnTypeScanType ")
- fmt.Printf(" -- row.results.Fields %#v \n", row.results.Fields[index].FieldType)
- fmt.Printf(" -- row.results.Fields %#v \n", row.results.Fields[index].scanType())
- return row.results.Fields[index].scanType()
- }
- func (self *xuguRows) Close() error {
- fmt.Println(">>>>>((self *xuguRows) Close() ")
- return nil
- }
|