forked from lunny/godbc
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathrows.go
45 lines (39 loc) · 825 Bytes
/
rows.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
// Copyright 2012 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
package odbc
import (
"database/sql/driver"
"github.com/lunny/godbc/api"
"io"
)
type Rows struct {
os *ODBCStmt
}
func (r *Rows) Columns() []string {
names := make([]string, len(r.os.Cols))
for i := 0; i < len(names); i++ {
names[i] = r.os.Cols[i].Name()
}
return names
}
func (r *Rows) Next(dest []driver.Value) error {
ret := api.SQLFetch(r.os.h)
if ret == api.SQL_NO_DATA {
return io.EOF
}
if IsError(ret) {
return NewError("SQLFetch", r.os.h)
}
for i := range dest {
v, err := r.os.Cols[i].Value(r.os.h, i)
if err != nil {
return err
}
dest[i] = v
}
return nil
}
func (r *Rows) Close() error {
return r.os.closeByRows()
}