rows.go

// 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/popeliv/odbc/api"
)

type Rows struct {
	os *ODBCStmt
}

func (r *Rows) ColumnTypeNullable(idx int) (nullable bool, ok bool) {
	return r.os.Cols[idx].Nullable()
}

func (r *Rows) ColumnTypeDatabaseTypeName(idx int) string {
	return r.os.Cols[idx].DatabaseTypeName()
}

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.SQLStmt.handle)
	if ret == api.SQL_NO_DATA {
		return io.EOF
	}
	if IsError(ret) {
		return NewError("SQLFetch", r.os.SQLStmt.handle)
	}
	for i := range dest {
		v, err := r.os.Cols[i].Value(r.os.SQLStmt.handle, 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.SQLStmt.handle)
	if ret == api.SQL_NO_DATA {
		return io.EOF
	}
	if IsError(ret) {
		return NewError("SQLMoreResults", r.os.SQLStmt.handle)
	}

	err := r.os.BindColumns()
	if err != nil {
		return err
	}
	return nil
}