// ======================================================================
//
// DbBindableVarray.cpp
// copyright (c) 2003 Sony Online Entertainment
//
// ======================================================================

#include "sharedDatabaseInterface/FirstSharedDatabaseInterface.h"
#include "DbBindableVarray.h"

#include "OciServer.h"
#include "OciSession.h"
#include "sharedFoundation/NetworkId.h"
#include "sharedLog/Log.h"
#include <oci.h>

// ======================================================================

using namespace DB;

// ======================================================================

BindableVarray::BindableVarray() :
		m_initialized(false),
		m_tdo (nullptr),
		m_data (nullptr),
		m_session (nullptr)
{
}

// ----------------------------------------------------------------------

BindableVarray::~BindableVarray()
{
	if (m_initialized)
		free();
}

// ----------------------------------------------------------------------

bool BindableVarray::create(DB::Session *session, const std::string &name, const std::string &schema)
{
	m_initialized = true;
	NOT_NULL(session);
	m_session = session;
	OCISession *localSession = safe_cast<OCISession*>(session);
		
	if (! (localSession->m_server->checkerr(*localSession, OCITypeByName (localSession->envhp,
					 localSession->errhp,
					 localSession->svchp,
					 reinterpret_cast<OraText*>(const_cast<char*>(schema.c_str())),
					 schema.length(),
					 reinterpret_cast<OraText*>(const_cast<char*>(name.c_str())),
					 name.length(),
					 nullptr,
					 0,
					 OCI_DURATION_SESSION,
					 OCI_TYPEGET_HEADER,
					 &m_tdo))))
		return false;

	if (! (localSession->m_server->checkerr(*localSession,
						OCIObjectNew (localSession->envhp,
						localSession->errhp,
						localSession->svchp,
						OCI_TYPECODE_VARRAY,
						m_tdo, nullptr,
						OCI_DURATION_DEFAULT,
						true,
						reinterpret_cast<void**>(&m_data)))))
		return false;

	NOT_NULL(m_tdo);
	NOT_NULL(m_data);

	return true;
}

// ----------------------------------------------------------------------

void BindableVarray::free()
{
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	IGNORE_RETURN(localSession->m_server->checkerr(*localSession,
						OCIObjectFree (localSession->envhp,
						localSession->errhp, m_data, 0)));
	m_initialized = false;
	m_tdo=nullptr;
	m_data=nullptr;
	m_session=nullptr;
}

// ----------------------------------------------------------------------

void BindableVarray::clear()
{
	OCISession *localSession = safe_cast<OCISession*>(m_session);
	sb4 size=0;

	if (! (localSession->m_server->checkerr(*localSession, OCICollSize(localSession->envhp, localSession->errhp, m_data, &size))))
		return;
	if (! (localSession->m_server->checkerr(*localSession, OCICollTrim(localSession->envhp, localSession->errhp, size, m_data))))
		return;
}

// ----------------------------------------------------------------------

OCIArray** BindableVarray::getBuffer()
{
	return &m_data;
}

// ----------------------------------------------------------------------

OCIType* BindableVarray::getTDO()
{
	return m_tdo;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(int value)
{
	OCINumber buffer;

	OCIInd buffer_indicator (OCI_IND_NOTNULL);

	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(long int value)
{
	OCINumber buffer;
	
	OCIInd buffer_indicator (OCI_IND_NOTNULL);
  	
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}
// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(int64 value)
{
	OCINumber buffer;
	
	OCIInd buffer_indicator (OCI_IND_NOTNULL);
  	
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(double value)
{
	if (finite(value)==0)
	{
		if (DB::Server::getFatalOnDataError())
		{
			FATAL(true,("DatabaseError:  Attempt to save a non-finite value to the database."));
		}
		else
		{
			value=0;
			WARNING_STACK_DEPTH(true,(INT_MAX,"DatabaseError:  Attempt to save a non-finite value to the database."));
		}
	}
		
	OCINumber buffer;

	OCIInd buffer_indicator (OCI_IND_NOTNULL);

	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromReal(localSession->errhp, &value, sizeof(value), &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(bool IsNULL, int value)
{
	OCINumber buffer;

 	OCIInd buffer_indicator;

 	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(bool IsNULL, long int value)
{
	OCINumber buffer;
	
 	OCIInd buffer_indicator;

 	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}
  	
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}
// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(bool IsNULL, int64 value)
{
	OCINumber buffer;
	
 	OCIInd buffer_indicator;

 	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}
  	
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromInt(localSession->errhp, &value, sizeof(value), OCI_NUMBER_SIGNED, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayNumber::push_back(bool IsNULL, double value)
{
	if (!IsNULL && finite(value)==0)
	{
		if (DB::Server::getFatalOnDataError())
		{
			FATAL(true,("DatabaseError:  Attempt to save a non-finite value to the database."));
		}
		else
		{
			value=0;
			WARNING_STACK_DEPTH(true,(INT_MAX,"DatabaseError:  Attempt to save a non-finite value to the database."));
		}
	}
	
	OCINumber buffer;

	OCIInd buffer_indicator;

	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}

	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCINumberFromReal(localSession->errhp, &value, sizeof(value), &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, &buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ======================================================================

BindableVarrayString::BindableVarrayString() :
		BindableVarray(),
		m_maxLength(0)
{
}

// ----------------------------------------------------------------------

std::string BindableVarrayNumber::outputValue() const
{
	OCISession *localSession = safe_cast<OCISession*>(m_session);
	sb4 size;
	std::string result("[");

	if (! (localSession->m_server->checkerr(*localSession, OCICollSize(localSession->envhp, localSession->errhp, m_data, &size))))
		return "[*ERROR*]";

	for (sb4 i=0; i < size; ++i)
	{
		OCINumber *element;
		OCIInd *indicator;
		boolean exists;
		
		if (i!=0)
			result += ", ";
		
		if (localSession->m_server->checkerr(*localSession, OCICollGetElem(localSession->envhp, localSession->errhp, m_data, i, &exists, reinterpret_cast<dvoid**>(&element), reinterpret_cast<dvoid**>(&indicator))))
		{
			if (exists)
			{
				if (*indicator == OCI_IND_NULL)
					result += "nullptr";
				else
				{
					double value;
					if (localSession->m_server->checkerr(*localSession, OCINumberToReal(localSession->errhp, element, sizeof(value), &value)))
					{
						char buffer[100];
						snprintf(buffer,sizeof(buffer),"%f",value);
						buffer[sizeof(buffer)-1]='\0';
						result += buffer;
					}
					else
						result += "*ERROR*";
				}
			}
			else
				result += "*NO ELEMENT*";			
		}
		else
			result += "*ERROR*";
	}
	result+=']';
	return result;
}

// ----------------------------------------------------------------------

bool BindableVarrayString::create(DB::Session *session, const std::string &name, const std::string &schema, size_t maxLength)
{
	m_maxLength=maxLength;
	return BindableVarray::create(session,name,schema);
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(const Unicode::String &value)
{
	std::string str;
	str = Unicode::wideToUTF8(value, str);
	return push_back(str);
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(const std::string &value)
{
	OCIString *buffer = nullptr;
	OCIInd buffer_indicator (OCI_IND_NOTNULL);
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	size_t effectiveLength=value.length();
	if (effectiveLength > m_maxLength)
	{
		if (DB::Server::getFatalOnDataError())
		{
			FATAL(true,("DatabaseError:  Attempt to save too long a string to the database:  \"%s\"",value.c_str()));
		}
		else
		{
			WARNING_STACK_DEPTH(true,(INT_MAX, "DatabaseError:  Attempt to save too long a string to the database.  (Text is in the log output.)"));
			LogManager::logLongText("DatabaseError",std::string("String from previous error is \"")+value+"\"");
			effectiveLength = m_maxLength;
		}
	}
	
	if (! (localSession->m_server->checkerr(*localSession, OCIStringAssignText(localSession->envhp, localSession->errhp, reinterpret_cast<OraText*>(const_cast<char*>(value.c_str())), effectiveLength, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(bool bvalue)
{
	std::string value;
	if (bvalue)
		value = "Y";
	else
		value = "N";
	
	OCIString *buffer = nullptr;
	OCIInd buffer_indicator (OCI_IND_NOTNULL);
	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCIStringAssignText(localSession->envhp, localSession->errhp, reinterpret_cast<OraText*>(const_cast<char*>(value.c_str())), value.length(), &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(const NetworkId &value)
{
	return push_back(value.getValueString());
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(bool IsNULL, const Unicode::String &value)
{
	std::string str;
	str = Unicode::wideToUTF8(value, str);
	return push_back(IsNULL, str);
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(bool IsNULL, const std::string &value)
{
	OCIString *buffer = nullptr;
	OCIInd buffer_indicator;
	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}

	size_t effectiveLength=value.length();
	if (effectiveLength > m_maxLength)
	{
		if (DB::Server::getFatalOnDataError())
		{
			FATAL(true,("DatabaseError:  Attempt to save too long a string to the database:  \"%s\"",value.c_str()));
		}
		else
		{
			WARNING_STACK_DEPTH(true,(INT_MAX, "DatabaseError:  Attempt to save too long a string to the database.  (Text is in the log output.)"));
			LogManager::logLongText("DatabaseError",std::string("String from previous error is \"")+value+"\"");
			effectiveLength = m_maxLength;
		}
	}

	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCIStringAssignText(localSession->envhp, localSession->errhp, reinterpret_cast<OraText*>(const_cast<char*>(value.c_str())), effectiveLength, &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(bool IsNULL, bool bvalue)
{
	std::string value;
	if (bvalue)
		value = "Y";
	else
		value = "N";
	
	OCIString *buffer = nullptr;
	OCIInd buffer_indicator;
	if ( IsNULL )
	{
		buffer_indicator = OCI_IND_NULL;
	}
	else
	{
		buffer_indicator = OCI_IND_NOTNULL;
	}

	OCISession *localSession = safe_cast<OCISession*>(m_session);

	if (! (localSession->m_server->checkerr(*localSession, OCIStringAssignText(localSession->envhp, localSession->errhp, reinterpret_cast<OraText*>(const_cast<char*>(value.c_str())), value.length(), &buffer))))
		return false;
	if (! (localSession->m_server->checkerr(*localSession, OCICollAppend(localSession->envhp, localSession->errhp, buffer, &buffer_indicator, m_data))))
		return false;

	return true;
}

// ----------------------------------------------------------------------

bool BindableVarrayString::push_back(bool IsNULL, const NetworkId &value)
{
	return push_back(IsNULL, value.getValueString());
}

// ----------------------------------------------------------------------

std::string BindableVarrayString::outputValue() const
{
	OCISession *localSession = safe_cast<OCISession*>(m_session);
	sb4 size;
	std::string result("[");

	if (! (localSession->m_server->checkerr(*localSession, OCICollSize(localSession->envhp, localSession->errhp, m_data, &size))))
		return "[*ERROR*]";

	for (sb4 i=0; i < size; ++i)
	{
		OCIString **element;
		OCIInd *indicator;
		boolean exists;
		
		if (i!=0)
			result += ", ";
		
		if (localSession->m_server->checkerr(*localSession, OCICollGetElem(localSession->envhp, localSession->errhp, m_data, i, &exists, reinterpret_cast<dvoid**>(&element), reinterpret_cast<dvoid**>(&indicator))))
		{
			if (exists)
			{
				if (*indicator == OCI_IND_NULL)
					result += "nullptr";
				else
				{
					OraText * text = OCIStringPtr(localSession->envhp, *element);
					if (text)
						result += '"' + std::string(reinterpret_cast<char*>(text)) + '"';
					else
						result += "nullptr";
				}
			}
			else
				result += "*NO ELEMENT*";			
		}
		else
			result += "*ERROR*";
	}
	result+=']';
	return result;
}

// ======================================================================