// Go MySQL Driver - A MySQL-Driver for Go's database/sql package // // Copyright 2012 The Go-MySQL-Driver Authors. All rights reserved. // // This Source Code Form is subject to the terms of the Mozilla Public // License, v. 2.0. If a copy of the MPL was not distributed with this file, // You can obtain one at http://mozilla.org/MPL/2.0/. package mysql import ( "database/sql/driver" "io" ) type mysqlField struct { tableName string name string flags fieldFlag fieldType byte decimals byte } type resultSet struct { columns []mysqlField done bool } type mysqlRows struct { mc *mysqlConn rs resultSet } type binaryRows struct { mysqlRows // stmtCols is a pointer to the statement's cached columns for different // result sets. stmtCols *[][]mysqlField // i is a number of the current result set. It is used to fetch proper // columns from stmtCols. i int } type textRows struct { mysqlRows } func (rows *mysqlRows) Columns() []string { columns := make([]string, len(rows.rs.columns)) if rows.mc != nil && rows.mc.cfg.ColumnsWithAlias { for i := range columns { if tableName := rows.rs.columns[i].tableName; len(tableName) > 0 { columns[i] = tableName + "." + rows.rs.columns[i].name } else { columns[i] = rows.rs.columns[i].name } } } else { for i := range columns { columns[i] = rows.rs.columns[i].name } } return columns } func (rows *mysqlRows) Close() (err error) { mc := rows.mc if mc == nil { return nil } if mc.netConn == nil { return ErrInvalidConn } // Remove unread packets from stream if !rows.rs.done { err = mc.readUntilEOF() } if err == nil { if err = mc.discardResults(); err != nil { return err } } rows.mc = nil return err } func (rows *mysqlRows) HasNextResultSet() (b bool) { if rows.mc == nil { return false } return rows.mc.status&statusMoreResultsExists != 0 } func (rows *mysqlRows) nextResultSet() (int, error) { if rows.mc == nil { return 0, io.EOF } if rows.mc.netConn == nil { return 0, ErrInvalidConn } // Remove unread packets from stream if !rows.rs.done { if err := rows.mc.readUntilEOF(); err != nil { return 0, err } rows.rs.done = true } if !rows.HasNextResultSet() { rows.mc = nil return 0, io.EOF } rows.rs = resultSet{} return rows.mc.readResultSetHeaderPacket() } func (rows *mysqlRows) nextNotEmptyResultSet() (int, error) { for { resLen, err := rows.nextResultSet() if err != nil { return 0, err } if resLen > 0 { return resLen, nil } rows.rs.done = true } } func (rows *binaryRows) NextResultSet() (err error) { resLen, err := rows.nextNotEmptyResultSet() if err != nil { return err } // get columns, if not cached, read them and cache them. if rows.i >= len(*rows.stmtCols) { rows.rs.columns, err = rows.mc.readColumns(resLen) *rows.stmtCols = append(*rows.stmtCols, rows.rs.columns) } else { rows.rs.columns = (*rows.stmtCols)[rows.i] if err := rows.mc.readUntilEOF(); err != nil { return err } } rows.i++ return nil } func (rows *binaryRows) Next(dest []driver.Value) error { if mc := rows.mc; mc != nil { if mc.netConn == nil { return ErrInvalidConn } // Fetch next row from stream return rows.readRow(dest) } return io.EOF } func (rows *textRows) NextResultSet() (err error) { resLen, err := rows.nextNotEmptyResultSet() if err != nil { return err } rows.rs.columns, err = rows.mc.readColumns(resLen) return err } func (rows *textRows) Next(dest []driver.Value) error { if mc := rows.mc; mc != nil { if mc.netConn == nil { return ErrInvalidConn } // Fetch next row from stream return rows.readRow(dest) } return io.EOF }