int IpfixDbWriterOracle::executeSql(string sql, oracle::occi::ResultSet *rs, oracle::occi::Statement *stmt, int prefetchRowCount = 1)
{
	rs = NULL;
	stmt = NULL;
	try
	{
		stmt = con->createStatement(sql);
	}
	catch (oracle::occi::SQLException& ex)
	{
		msg(MSG_FATAL,"IpfixDbWriterOracle: %s", ex.getMessage().c_str());
		return 1;
	}
	if (stmt)
	{
		try
		{
			stmt->setPrefetchRowCount(prefetchRowCount);
			rs = stmt->executeQuery();
			return 0;
		}
		catch (oracle::occi::SQLException& ex)
		{
			msg(MSG_FATAL,"IpfixDbWriterOracle: %s", ex.getMessage().c_str());
			return 1;
		}
	}
	return 1;
}