-
Notifications
You must be signed in to change notification settings - Fork 141
/
rows.go
66 lines (56 loc) · 1.13 KB
/
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
// 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"
"io"
"github.com/alexbrainman/odbc/api"
)
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()
}
func (r *Rows) HasNextResultSet() bool {
return true
}
func (r *Rows) NextResultSet() error {
ret := api.SQLMoreResults(r.os.h)
if ret == api.SQL_NO_DATA {
return io.EOF
}
if IsError(ret) {
return NewError("SQLMoreResults", r.os.h)
}
err := r.os.BindColumns()
if err != nil {
return err
}
return nil
}