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/manipulator.h>
26
#include <sqlite3cc/database.h>
26
27
#include <assert.h>
29
30
sqlite::query::query(
30
connection &connection,
31
32
const std::string &sql )
33
basic_statement( connection, sql ),
34
basic_statement( database, sql ),
36
37
assert( sqlite3_column_count( _handle ) > 0 );
40
41
sqlite::query::query(
41
connection &connection )
43
basic_statement( connection ),
44
basic_statement( database ),
49
50
int sqlite::query::prepare(
50
51
const std::string &sql )
53
54
int code = basic_statement::prepare( sql );
54
55
assert( code != SQLITE_OK || sqlite3_column_count( _handle ) > 0 );
59
int sqlite::query::reset()
62
return basic_statement::reset();
66
60
sqlite::row sqlite::query::step()
68
connection::mutex_guard lock( _connection );
62
database::database_mutex_guard lock( _database );
70
64
int code = basic_statement::step();
71
65
if( code == SQLITE_DONE ) return row();
72
if( code == SQLITE_ROW ) return row( _handle, _next_row_number++ );
66
if( code == SQLITE_ROW ) return row( _handle, _next_row++ );
74
throw sqlite_error( _connection, code );
68
throw sqlite_error( _database, code );
93
unsigned long long sqlite::query::num_results()
96
unsigned long long count = 0;
97
while( step() ) count++;
103
87
sqlite::query::iterator::iterator(
104
88
sqlite::query &query,
109
if( step ) increment();
113
100
sqlite::row sqlite::query::iterator::dereference() const
102
return sqlite::row( _query._handle, _query._next_row++ );
119
106
void sqlite::query::iterator::increment()
121
_row = _query.step();
108
_valid = _query.step();
126
113
sqlite::query::iterator const &other )
129
return _row == other._row;
116
return _valid == other._valid;
133
120
sqlite::query::iterator sqlite::query::begin()
136
122
return sqlite::query::iterator( *this, true );
142
128
return sqlite::query::iterator( *this, false );
133
sqlite::query &sqlite::query::operator <<
134
< sqlite::detail::null_t >(
135
const sqlite::detail::null_t & )
137
int code = bind_null( _bind_index );
138
if( code != SQLITE_OK ) throw sqlite_error( _database, code );
145
sqlite::query &sqlite::query::operator <<
146
< sqlite::detail::set_index_t >(
147
const sqlite::detail::set_index_t &t )
149
_bind_index = t._index;