X-Git-Url: https://git.pterodactylus.net/?p=fms.git;a=blobdiff_plain;f=src%2Fdb%2Fsqlite3statement.cpp;h=7ef5e278d61f0c9da3443dfd1030cdb602dc3f7e;hp=edb2f60a4bbb20ea3f2ac0c263e6ad3b1265009c;hb=59a5414ec47a2932a7802fcd1d98c4d80166564f;hpb=d8f51eac91f86a1e00a05a5058a8fa9eb8732464

diff --git a/src/db/sqlite3statement.cpp b/src/db/sqlite3statement.cpp
index edb2f60..7ef5e27 100644
--- a/src/db/sqlite3statement.cpp
+++ b/src/db/sqlite3statement.cpp
@@ -1,5 +1,13 @@
 #include "../../include/db/sqlite3db/sqlite3statement.h"
 
+#ifdef QUERY_LOG
+#include <Poco/Logger.h>
+#include <Poco/FormattingChannel.h>
+#include <Poco/PatternFormatter.h>
+#include <Poco/FileChannel.h>
+#include "../../include/stringfunctions.h"
+#endif
+
 #ifdef XMEM
 	#include <xmem.h>
 #endif
@@ -7,58 +15,40 @@
 namespace SQLite3DB
 {
 
+Poco::FastMutex Statement::m_mutex;
 std::map<sqlite3_stmt *, long> Statement::m_statementcount;
 
-Statement::Statement()
+Statement::Statement():m_statement(0),m_parametercount(0),m_resultcolumncount(0),m_rowreturned(false),m_lastinsertrowid(-1)
 {
-	m_statement=NULL;
-	m_parametercount=0;
-	m_resultcolumncount=0;
-	m_rowreturned=false;
+
 }
 
-Statement::Statement(sqlite3_stmt *statement)
+Statement::Statement(sqlite3_stmt *statement):m_statement(statement),m_rowreturned(false),m_lastinsertrowid(-1)
 {
-	m_statement=statement;
 	m_parametercount=sqlite3_bind_parameter_count(m_statement);
 	m_resultcolumncount=sqlite3_column_count(m_statement);
-	m_rowreturned=false;
-	
+
 	if(m_statement)
 	{
+		Poco::ScopedLock<Poco::FastMutex> g(m_mutex);
 		m_statementcount[m_statement]++;
 	}
 }
 
-Statement::Statement(Statement &rhs)
+Statement::Statement(const Statement &rhs):m_statement(0),m_parametercount(0),m_resultcolumncount(0),m_rowreturned(false),m_lastinsertrowid(-1)
 {
-	m_statement=NULL;
-	m_parametercount=0;
-	m_resultcolumncount=0;
-	m_rowreturned=false;
 	*this=rhs;
 }
 
 Statement::~Statement()
 {
-	
 	Finalize();
-	
-	std::vector<char *>::iterator i;
-	for(i=textptrs.begin(); i!=textptrs.end(); i++)
-	{
-		if((*i))
-		{
-			delete [] (*i);
-		}
-	}
 }
 
 const bool Statement::Bind(const int column)
 {
 	if(Valid() && column>=0 && column<m_parametercount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		if(sqlite3_bind_null(m_statement,column+1)==SQLITE_OK)
 		{
 			return true;
@@ -78,7 +68,6 @@ const bool Statement::Bind(const int column, const int value)
 {
 	if(Valid() && column>=0 && column<m_parametercount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		if(sqlite3_bind_int(m_statement,column+1,value)==SQLITE_OK)
 		{
 			return true;
@@ -98,7 +87,6 @@ const bool Statement::Bind(const int column, const double value)
 {
 	if(Valid() && column>=0 && column<m_parametercount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		if(sqlite3_bind_double(m_statement,column+1,value)==SQLITE_OK)
 		{
 			return true;
@@ -118,12 +106,7 @@ const bool Statement::Bind(const int column, const std::string &value)
 {
 	if(Valid() && column>=0 && column<m_parametercount)
 	{
-		char *text=new char[value.size()+1];
-		strncpy(text,value.c_str(),value.size());
-		text[value.size()]=NULL;
-		textptrs.push_back(text);
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
-		if(sqlite3_bind_text(m_statement,column+1,text,value.size(),NULL)==SQLITE_OK)
+		if(sqlite3_bind_text(m_statement,column+1,value.c_str(),value.size(),SQLITE_TRANSIENT)==SQLITE_OK)
 		{
 			return true;
 		}
@@ -142,8 +125,7 @@ const bool Statement::Bind(const int column, const void *data, const int length)
 {
 	if(Valid() && column>=0 && column<m_parametercount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
-		if(sqlite3_bind_blob(m_statement,column+1,data,length,NULL)==SQLITE_OK)
+		if(sqlite3_bind_blob(m_statement,column+1,data,length,SQLITE_TRANSIENT)==SQLITE_OK)
 		{
 			return true;
 		}
@@ -162,7 +144,7 @@ void Statement::Finalize()
 {
 	if(m_statement)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
+		Poco::ScopedLock<Poco::FastMutex> g(m_mutex);
 		m_statementcount[m_statement]--;
 		if(m_statementcount[m_statement]<=0)
 		{
@@ -183,10 +165,11 @@ Statement &Statement::operator=(const Statement &rhs)
 		m_parametercount=rhs.m_parametercount;
 		m_resultcolumncount=rhs.m_resultcolumncount;
 		m_rowreturned=rhs.m_rowreturned;
+		m_lastinsertrowid=rhs.m_lastinsertrowid;
 
 		if(m_statement)
 		{
-			ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
+			Poco::ScopedLock<Poco::FastMutex> g(m_mutex);
 			m_statementcount[m_statement]++;
 		}
 	}
@@ -197,7 +180,6 @@ const bool Statement::Reset()
 {
 	if(Valid())
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		if(sqlite3_reset(m_statement)==SQLITE_OK)
 		{
 			return true;
@@ -217,9 +199,24 @@ const bool Statement::ResultBlob(const int column, void *data, int &length)
 {
 	if(Valid() && column>=0 && column<m_resultcolumncount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
-		data=(void *)sqlite3_column_blob(m_statement,column);
-		length=sqlite3_column_bytes(m_statement,column);
+		int bloblength=sqlite3_column_bytes(m_statement,column);
+		if(bloblength>length)
+		{
+			bloblength=length;
+		}
+		if(bloblength<length)
+		{
+			length=bloblength;
+		}
+		const void *blobptr=sqlite3_column_blob(m_statement,column);
+		if(blobptr)
+		{
+			std::copy((unsigned char *)blobptr,(unsigned char *)blobptr+bloblength,(unsigned char *)data);
+		}
+		else
+		{
+			length=0;
+		}
 		return true;
 	}
 	else
@@ -232,7 +229,6 @@ const bool Statement::ResultDouble(const int column, double &result)
 {
 	if(Valid() && column>=0 && column<m_resultcolumncount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		result=sqlite3_column_double(m_statement,column);
 		return true;
 	}
@@ -246,7 +242,6 @@ const bool Statement::ResultInt(const int column, int &result)
 {
 	if(Valid() && column>=0 && column<m_resultcolumncount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		result=sqlite3_column_int(m_statement,column);
 		return true;
 	}
@@ -260,7 +255,6 @@ const bool Statement::ResultNull(const int column)
 {
 	if(Valid() && column>=0 && column<m_resultcolumncount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		if(sqlite3_column_type(m_statement,column)==SQLITE_NULL)
 		{
 			return true;
@@ -280,7 +274,6 @@ const bool Statement::ResultText(const int column, std::string &result)
 {
 	if(Valid() && column>=0 && column<m_resultcolumncount)
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		const unsigned char *cresult=sqlite3_column_text(m_statement,column);
 		if(cresult)
 		{
@@ -303,8 +296,13 @@ const bool Statement::Step(const bool saveinsertrowid)
 	m_rowreturned=false;
 	if(Valid())
 	{
-		ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 		int result=sqlite3_step(m_statement);
+#ifdef QUERY_LOG
+		size_t temp=reinterpret_cast<size_t>(m_statement);
+		std::string tempstr("");
+		StringFunctions::Convert(temp,tempstr);
+		Poco::Logger::get("querylog").information("Step : "+tempstr);
+#endif
 		if(result==SQLITE_OK || result==SQLITE_ROW || result==SQLITE_DONE)
 		{
 			if(result==SQLITE_ROW)
@@ -313,7 +311,7 @@ const bool Statement::Step(const bool saveinsertrowid)
 			}
 			if(saveinsertrowid)
 			{
-				m_lastinsertrowid=sqlite3_last_insert_rowid(DB::instance()->GetDB());
+				m_lastinsertrowid=sqlite3_last_insert_rowid(sqlite3_db_handle(m_statement));
 			}
 			return true;
 		}
@@ -330,7 +328,6 @@ const bool Statement::Step(const bool saveinsertrowid)
 
 const bool Statement::Valid()
 {
-	ZThread::Guard<ZThread::Mutex> g(DB::instance()->m_mutex);
 	return m_statement ? true : false ;
 }