/sqlite3cc : contents of src/command.cc at revision 18

: (revision 18)

To get this branch, use:

bzr branch
http://bzr.ed.am/sqlite3cc

/*
 * command.cc
 *
 * Copyright (C) 2009 Tim Marston <edam@waxworlds.org>
 *
 * This file is part of sqlite3cc (hereafter referred to as "this program").
 * See http://www.waxworlds.org/edam/software/sqlite3cc for more information.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published
 * by the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <sqlite3cc/command.h>
#include <sqlite3cc/connection.h>
#include <sqlite3cc/manipulator.h>
#include <cassert>


sqlite::command::command(
	connection &connection,
	const std::string &sql )
	:
	detail::basic_statement( connection, sql ),
	_changes( 0 ),
	_total_changes( 0 ),
	_last_insert_rowid( 0 )
{
	assert( sqlite3_column_count( _handle ) == 0 );
}


sqlite::command::command(
	connection &connection )
	:
	detail::basic_statement( connection ),
	_changes( 0 ),
	_total_changes( 0 ),
	_last_insert_rowid( 0 )
{
}


int sqlite::command::prepare(
	const std::string &sql )
{
	int code = detail::basic_statement::prepare( sql );
	assert( code != SQLITE_OK || sqlite3_column_count( _handle ) == 0 );
	return code;
}


int sqlite::command::step()
{
	connection::mutex_guard lock( _connection );

	int code = detail::basic_statement::step();
	if( code == SQLITE_ROW ) throw sqlite_error( "command has results" );
	if( code != SQLITE_DONE ) throw sqlite_error( _connection, code );

	_changes = sqlite3_changes( _connection._handle );
	_total_changes = sqlite3_total_changes( _connection._handle );
	_last_insert_rowid = sqlite3_last_insert_rowid( _connection._handle );

	lock.leave();

	// finalise now (which shouldn't matter for commands), so that there are no
	// active statements if we come to begin, commit or rollback a transaction
	finalize();

	return code;
}


template< >
sqlite::detail::basic_statement &sqlite::detail::basic_statement::operator <<
	< sqlite::detail::exec_t >(
	const sqlite::detail::exec_t & )
{
	sqlite::command &that = dynamic_cast< sqlite::command & >( *this );

	int code = that.step();
	if( code != SQLITE_DONE ) {
		if( code == SQLITE_ROW )
			throw sqlite_error( "statement returned results" );
		else
			throw sqlite_error( _connection, code );
	}
	return *this;
}


2 by edam - further initial development	1	/*
	2	* command.cc
	3	*
	4	* Copyright (C) 2009 Tim Marston <edam@waxworlds.org>
	5	*
	6	* This file is part of sqlite3cc (hereafter referred to as "this program").
	7	* See http://www.waxworlds.org/edam/software/sqlite3cc for more information.
	8	*
	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.
	13	*
	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.
	18	*
	19	* You should have received a copy of the GNU Lesser General Public License
	20	* along with this program. If not, see <http://www.gnu.org/licenses/>.
	21	*/
	22
	23	#include <sqlite3cc/command.h>
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	24	#include <sqlite3cc/connection.h>
13 by edam - made basic_statement::step() protected, for use by query and command only	25	#include <sqlite3cc/manipulator.h>
2 by edam - further initial development	26	#include <cassert>
	27
	28
	29	sqlite::command::command(
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	30	connection &connection,
2 by edam - further initial development	31	const std::string &sql )
2 by edam - further initial development	32	:
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	33	detail::basic_statement( connection, sql ),
2 by edam - further initial development	34	_changes( 0 ),
	35	_total_changes( 0 ),
	36	_last_insert_rowid( 0 )
	37	{
	38	assert( sqlite3_column_count( _handle ) == 0 );
	39	}
	40
	41
	42	sqlite::command::command(
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	43	connection &connection )
2 by edam - further initial development	44	:
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	45	detail::basic_statement( connection ),
2 by edam - further initial development	46	_changes( 0 ),
	47	_total_changes( 0 ),
	48	_last_insert_rowid( 0 )
	49	{
	50	}
	51
	52
	53	int sqlite::command::prepare(
	54	const std::string &sql )
	55	{
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	56	int code = detail::basic_statement::prepare( sql );
13 by edam - made basic_statement::step() protected, for use by query and command only	57	assert( code != SQLITE_OK \|\| sqlite3_column_count( _handle ) == 0 );
	58	return code;
2 by edam - further initial development	59	}
	60
	61
	62	int sqlite::command::step()
	63	{
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	64	connection::mutex_guard lock( _connection );
13 by edam - made basic_statement::step() protected, for use by query and command only	65
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	66	int code = detail::basic_statement::step();
13 by edam - made basic_statement::step() protected, for use by query and command only	67	if( code == SQLITE_ROW ) throw sqlite_error( "command has results" );
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	68	if( code != SQLITE_DONE ) throw sqlite_error( _connection, code );
13 by edam - made basic_statement::step() protected, for use by query and command only	69
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	70	_changes = sqlite3_changes( _connection._handle );
	71	_total_changes = sqlite3_total_changes( _connection._handle );
	72	_last_insert_rowid = sqlite3_last_insert_rowid( _connection._handle );
13 by edam - made basic_statement::step() protected, for use by query and command only	73
	74	lock.leave();
	75
	76	// finalise now (which shouldn't matter for commands), so that there are no
	77	// active statements if we come to begin, commit or rollback a transaction
	78	finalize();
	79
	80	return code;
	81	}
	82
	83
	84	template< >
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	85	sqlite::detail::basic_statement &sqlite::detail::basic_statement::operator <<
13 by edam - made basic_statement::step() protected, for use by query and command only	86	< sqlite::detail::exec_t >(
	87	const sqlite::detail::exec_t & )
	88	{
14 by edam - moved basic_statement::operator <<() back to basic_statement and just create another specialisation in command so that it can use sqlite::exec	89	sqlite::command &that = dynamic_cast< sqlite::command & >( *this );
	90
	91	int code = that.step();
13 by edam - made basic_statement::step() protected, for use by query and command only	92	if( code != SQLITE_DONE ) {
	93	if( code == SQLITE_ROW )
	94	throw sqlite_error( "statement returned results" );
	95	else
16 by edam - renamed database to connection to better identify what it is (would database_connection be better though?)	96	throw sqlite_error( _connection, code );
2 by edam - further initial development	97	}
13 by edam - made basic_statement::step() protected, for use by query and command only	98	return *this;
	99	}
	100