DB::Sqlite3_Connection Class Reference

#include <sqlite3_db.h>

Inheritance diagram for DB::Sqlite3_Connection:

List of all members.

Public Member Functions
	Sqlite3_Connection ()
	~Sqlite3_Connection ()
bool	open (const char *database, const char *host, const int port, const char *user, const char *pass)
bool	close (void)
bool	isConnected (void)
bool	execute (const char *sql)
ResultSet *	executeQuery (const char *sql)
char *	escape (const char *)
const char *	unixtimeToSql (const time_t)
const unsigned long	insertId (void)
bool	beginTrans (void)
bool	commitTrans (void)
bool	rollbackTrans (void)
bool	setTransactionMode (const enum TRANS_MODE mode)
unsigned int	errorno (void) const
const char *	errormsg (void) const
const char *	version (void) const
void *	operator new (size_t bytes)
void	operator delete (void *ptr)
Private Member Functions
	Sqlite3_Connection (const Sqlite3_Connection &old)
const Sqlite3_Connection &	operator= (const Sqlite3_Connection &old)
Private Attributes
sqlite3 *	db_
int	errorno_
std::string	errormsg_

---

Detailed Description

Definition at line 75 of file sqlite3_db.h.

---

Constructor & Destructor Documentation

DB::Sqlite3_Connection::Sqlite3_Connection

(

const Sqlite3_Connection &

old

)

[private]

DB::Sqlite3_Connection::Sqlite3_Connection

(

)

[inline]

Definition at line 82 of file sqlite3_db.h.

: db_(NULL) {};

DB::Sqlite3_Connection::~Sqlite3_Connection

(

)

[inline]

Definition at line 83 of file sqlite3_db.h.

References close().

{ close(); }

---

Member Function Documentation

bool DB::Sqlite3_Connection::beginTrans

(

void

)

[virtual]

Begins a new transaction. If for some reason it fails, false will be returned (for instance, if the underlying driver does not support transactions.)

Returns:

bool

Implements DB::Connection.

Definition at line 318 of file sqlite3_db.cpp.

References db_, and execute().

{
    if (!db_) return (false);
    return (execute("BEGIN TRANSACTION"));
}

bool DB::Sqlite3_Connection::close

(

void

)

[virtual]

Close the database connection

Returns:

bool True if successful.

Implements DB::Connection.

Definition at line 233 of file sqlite3_db.cpp.

References db_.

Referenced by ~Sqlite3_Connection().

{
    if (!db_) return (false);
    if (sqlite3_close(db_) != SQLITE_OK) {
        return (false);
    }
    db_ = NULL;
    return (true);
}

bool DB::Sqlite3_Connection::commitTrans

(

void

)

[virtual]

Attempts to commit the current transaction

Returns:

bool

Implements DB::Connection.

Definition at line 325 of file sqlite3_db.cpp.

References db_, and execute().

{
    if (!db_) return (false);
    return (execute("COMMIT TRANSACTION"));
}

const char * DB::Sqlite3_Connection::errormsg

(

void

)

const [virtual]

Returns a textual representation of the last error to occur. The value returned should NOT be freed.

Returns:

const char*

Implements DB::Connection.

Definition at line 369 of file sqlite3_db.cpp.

References db_.

{
    return (sqlite3_errmsg(db_));
}

unsigned int DB::Sqlite3_Connection::errorno

(

void

)

const [virtual]

Returns the last error code to occur.

Returns:

unsigned int

Implements DB::Connection.

Definition at line 363 of file sqlite3_db.cpp.

References db_.

{
    return ((unsigned int) sqlite3_errcode(db_));
}

char * DB::Sqlite3_Connection::escape

(

const char *

)

[virtual]

Returns a database specific escaped string from the input. The string returned must be freed by the caller. This is used by the Query class.

Returns:

char*

Implements DB::Connection.

Definition at line 285 of file sqlite3_db.cpp.

{
    /* this is overly complex so that valgrind doesn't report a mismatched
     * delete, free, delete[].
     */
    char *esc = sqlite3_mprintf("\'%q\'", str);
    char *ret = new char[strlen(esc) + 1];
    strcpy(ret, esc);
    free(esc);
    return (ret);

}

bool DB::Sqlite3_Connection::execute

(

const char *

sql

)

[virtual]

Executes a query to the database, discarding any result data. This function is typically used for non-SELECT statements.

Parameters:

sql

Returns:

bool

Implements DB::Connection.

Definition at line 251 of file sqlite3_db.cpp.

References db_.

Referenced by beginTrans(), commitTrans(), rollbackTrans(), and setTransactionMode().

{
    bool ret = false;
    char *err = NULL;

    if (!db_) return (ret);

    if (sqlite3_exec(db_, sql, NULL, NULL, &err) == SQLITE_OK) {
        ret = true;
    }
    if (err) {
        sqlite3_free(err);
    }
    return (ret);
}

DB::ResultSet * DB::Sqlite3_Connection::executeQuery

(

const char *

sql

)

[virtual]

Executes a query to the database which returns row data. The row data is manipulated using the ResultSet object returned by this method. If the database wasn't able to return row data or an error occurs, then zero is returned. Therefore be careful to check the returned value, before using it - or a seg. fault is possible!

Parameters:

sql

Returns:

ResultSet*

Implements DB::Connection.

Definition at line 268 of file sqlite3_db.cpp.

References db_.

{
    sqlite3_stmt *vm = NULL;
    const char *tail = NULL;

    if (!db_) return (false);

    if (sqlite3_prepare(db_, sql, -1, &vm, &tail) != SQLITE_OK) {
        return (0);
    }

    DB::ResultSet *c = 0;
    ACE_NEW_RETURN (c, DB::Sqlite3_ResultSet(vm), 0);
    return (c);
}

const unsigned long DB::Sqlite3_Connection::insertId

(

void

)

[virtual]

Returns the last SQL INSERT unique identifier if the underlying database supports this feature.

Returns:

const unsigned long

Implements DB::Connection.

Definition at line 312 of file sqlite3_db.cpp.

References db_.

{
    return ((const unsigned long) sqlite3_last_insert_rowid(db_));
}

bool DB::Sqlite3_Connection::isConnected

(

void

)

[virtual]

Attempts to tell if we are still connected to the database.

Returns:

bool

Implements DB::Connection.

Definition at line 244 of file sqlite3_db.cpp.

References db_.

{
    if (!db_) return (false);
    return (true);
}

bool DB::Sqlite3_Connection::open	(	const char *	database,
		const char *	host,
		const int	port,
		const char *	user,
		const char *	pass
	)			[virtual]

Open a connection to a database.

Parameters:

	database	Database name. Sqlite3 uses this for the filename.
	host	Hostname
	port	Port
	user	Username
	pass	Password

Returns:

bool True if successful.

Implements DB::Connection.

Definition at line 223 of file sqlite3_db.cpp.

References db_.

{
    if (sqlite3_open(database, &db_) != SQLITE_OK) {
        db_ = NULL;
        return (false);
    }
    return (true);
}

void DB::Sqlite3_Connection::operator delete

(

void *

ptr

)

Definition at line 402 of file sqlite3_db.cpp.

{
  delete [] static_cast <char *> (ptr);
}

void * DB::Sqlite3_Connection::operator new

(

size_t

bytes

)

Definition at line 383 of file sqlite3_db.cpp.

{
  return (::new char[bytes]);
}

const Sqlite3_Connection& DB::Sqlite3_Connection::operator=

(

const Sqlite3_Connection &

old

)

[private]

bool DB::Sqlite3_Connection::rollbackTrans

(

void

)

[virtual]

Attempts to rollback the current transaction

Returns:

bool

Implements DB::Connection.

Definition at line 332 of file sqlite3_db.cpp.

References db_, and execute().

{
    if (!db_) return (false);
    return (execute("ROLLBACK TRANSACTION"));
}

bool DB::Sqlite3_Connection::setTransactionMode

(

const enum TRANS_MODE

mode

)

Definition at line 339 of file sqlite3_db.cpp.

References execute(), DB::Connection::READ_COMMITTED, DB::Connection::READ_UNCOMMITTED, DB::Connection::REPEATABLE_READ, and DB::Connection::SERIALIZABLE.

{
    const char *sql = "";

    switch (mode) {
    case READ_UNCOMMITTED:
        sql = "SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED";
        break;
    case READ_COMMITTED:
        sql = "SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED";
        break;
    case REPEATABLE_READ:
        sql = "SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ";
        break;
    case SERIALIZABLE:
        sql = "SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE";
        break;
    default:
        return false;
    }
    return (execute(sql));
}

const char * DB::Sqlite3_Connection::unixtimeToSql

(

const

time_t

)

[virtual]

Returns a database specific representation of the time_t value. This is used by the Query class. The string returned must be freed by the caller.

Parameters:

time_t

Returns:

const char*

Implements DB::Connection.

Definition at line 299 of file sqlite3_db.cpp.

{
    char *buf = new char[22];
    struct tm *tmp = new struct tm;
    buf[0] = '\'';
    ACE_OS::strftime(buf+1, 20, "%Y-%m-%d %H:%M:%S", ACE_OS::localtime_r(&val, tmp));
    buf[20] = '\'';
    buf[21] = 0;
    delete tmp;
    return (buf);
}

const char * DB::Sqlite3_Connection::version

(

void

)

const [virtual]

Returns the DB abstraction module's version number and possibly the version of the underlying database client library used. The returned value should NOT be freed.

Returns:

const char*

Implements DB::Connection.

Definition at line 375 of file sqlite3_db.cpp.

{
    static char ret[256];
    ACE_OS::snprintf(ret, 256, "Sqlite3 Driver v0.1 using %s", sqlite3_libversion());
    return ((const char *) ret);
}

---

Member Data Documentation

sqlite3* DB::Sqlite3_Connection::db_ [private]

Definition at line 118 of file sqlite3_db.h.

Referenced by beginTrans(), close(), commitTrans(), errormsg(), errorno(), execute(), executeQuery(), insertId(), isConnected(), open(), and rollbackTrans().

std::string DB::Sqlite3_Connection::errormsg_ [private]

Definition at line 120 of file sqlite3_db.h.

int DB::Sqlite3_Connection::errorno_ [private]

Definition at line 119 of file sqlite3_db.h.

---

The documentation for this class was generated from the following files:

• sqlite3_db.h
• sqlite3_db.cpp

---