4
* Copyright (C) 2009 Tim Marston <tim@ed.am>
4
* Copyright (C) 2009 Tim Marston <edam@waxworlds.org>
6
6
* This file is part of sqlite3cc (hereafter referred to as "this program").
7
* See http://ed.am/dev/sqlite3cc for more information.
9
* This program is free software: you can redistribute it and/or modify it under
10
* the terms of the GNU Lesser General Public License as published by the Free
11
* Software Foundation, either version 3 of the License, or (at your option) any
14
* This program is distributed in the hope that it will be useful, but WITHOUT
15
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
16
* FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
7
* See http://www.waxworlds.org/edam/software/sqlite3cc for more information.
9
* This program is free software: you can redistribute it and/or modify
10
* it under the terms of the GNU Lesser General Public License as published
11
* by the Free Software Foundation, either version 3 of the License, or
12
* (at your option) any later version.
14
* This program is distributed in the hope that it will be useful,
15
* but WITHOUT ANY WARRANTY; without even the implied warranty of
16
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17
* GNU Lesser General Public License for more details.
19
19
* You should have received a copy of the GNU Lesser General Public License
20
20
* along with this program. If not, see <http://www.gnu.org/licenses/>.
23
23
#include <sqlite3cc/query.h>
24
24
#include <sqlite3cc/row.h>
25
#include <sqlite3cc/connection.h>
25
#include <sqlite3cc/database.h>
29
29
sqlite::query::query(
30
connection &connection,
31
31
const std::string &sql )
33
basic_statement( connection, sql ),
33
basic_statement( database, sql ),
36
36
assert( sqlite3_column_count( _handle ) > 0 );
40
40
sqlite::query::query(
41
connection &connection )
43
basic_statement( connection ),
43
basic_statement( database ),
49
49
int sqlite::query::prepare(
50
50
const std::string &sql )
53
53
int code = basic_statement::prepare( sql );
54
54
assert( code != SQLITE_OK || sqlite3_column_count( _handle ) > 0 );
59
int sqlite::query::reset()
62
return basic_statement::reset();
66
59
sqlite::row sqlite::query::step()
68
connection::mutex_guard lock( _connection );
61
database::database_mutex_guard lock( _database );
70
63
int code = basic_statement::step();
71
64
if( code == SQLITE_DONE ) return row();
72
if( code == SQLITE_ROW ) return row( _handle, _next_row_number++ );
65
if( code == SQLITE_ROW ) return row( _handle, _next_row++ );
74
throw sqlite_error( _connection, code );
67
throw sqlite_error( _database, code );
93
unsigned long long sqlite::query::num_results()
96
unsigned long long count = 0;
97
while( step() ) count++;
103
86
sqlite::query::iterator::iterator(
104
87
sqlite::query &query,
109
if( step ) increment();
113
99
sqlite::row sqlite::query::iterator::dereference() const
101
return sqlite::row( _query._handle, _query._next_row++ );
119
105
void sqlite::query::iterator::increment()
121
_row = _query.step();
107
_valid = _query.step();
126
112
sqlite::query::iterator const &other )
129
return _row == other._row;
115
return _valid == other._valid;
133
119
sqlite::query::iterator sqlite::query::begin()
136
121
return sqlite::query::iterator( *this, true );