/*
 * Copyright (C) 2010-2011, Mathieu Labbe and IntRoLab - Universite de Sherbrooke
 *
 * This file is part of RTAB-Map.
 *
 * RTAB-Map is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * RTAB-Map 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with RTAB-Map.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef DBDRIVERSQLITE3_H_
#define DBDRIVERSQLITE3_H_

#include "rtabmap/core/RtabmapExp.h" // DLL export/import defines
#include "rtabmap/core/DBDriver.h"

#include <sqlite3.h>

namespace rtabmap {

class RTABMAP_EXP DBDriverSqlite3: public DBDriver {
public:
	DBDriverSqlite3(const ParametersMap & parameters = ParametersMap());
	virtual ~DBDriverSqlite3();

	virtual std::string getDriverName() const {return "sqlite3";}
	virtual void parseParameters(const ParametersMap & parameters);
	void setDbInMemory(bool dbInMemory);
	void setJournalMode(int journalMode);
	void setCacheSize(unsigned int cacheSize);
	void setSynchronous(int synchronous);
	void setTempStore(int tempStore);

private:
	virtual bool connectDatabaseQuery(const std::string & url, bool overwirtten = false);
	virtual void disconnectDatabaseQuery();
	virtual bool isConnectedQuery() const;
	virtual long getMemoryUsedQuery() const; // In bytes

	virtual bool executeNoResultQuery(const std::string & sql) const;

	virtual bool changeWordsRefQuery(const std::map<int, int> & refsToChange) const; // <oldWordId, activeWordId>
	virtual bool deleteWordsQuery(const std::vector<int> & ids) const;
	virtual bool getNeighborIdsQuery(int signatureId, std::set<int> & neighbors, bool onlyWithActions = false) const;
	virtual bool getWeightQuery(int signatureId, int & weight) const;
	virtual bool getLoopClosureIdsQuery(int signatureId, std::set<int> & loopIds, std::set<int> & childIds) const;

	virtual bool saveQuery(const std::vector<VisualWord *> & visualWords) const;
	virtual bool updateQuery(const std::list<Signature *> & signatures) const;
	virtual bool saveQuery(const std::list<Signature *> & signatures) const;

	// Load objects
	virtual bool loadQuery(VWDictionary * dictionary) const;
	virtual bool loadLastNodesQuery(std::list<Signature *> & signatures) const;
	virtual bool loadQuery(int signatureId, Signature ** s) const;
	virtual bool loadQuery(int wordId, VisualWord ** vw) const;
	virtual bool loadQuery(int signatureId, KeypointSignature * ss) const;
	virtual bool loadQuery(int signatureId, SMSignature * ss) const;
	virtual bool loadKeypointSignaturesQuery(const std::list<int> & ids, std::list<Signature *> & signatures) const;
	virtual bool loadSMSignaturesQuery(const std::list<int> & ids, std::list<Signature *> & signatures) const;
	virtual bool loadWordsQuery(const std::list<int> & wordIds, std::list<VisualWord *> & vws) const;
	virtual bool loadNeighborsQuery(int signatureId, NeighborsMultiMap & neighbors) const;
	bool loadLinksQuery(std::list<Signature *> & signatures) const;

	virtual bool getRawDataQuery(int id, std::list<Sensor> & rawData) const;
	virtual bool getActuatorDataQuery(int id, std::list<Actuator> & data) const;
	virtual bool getAllNodeIdsQuery(std::set<int> & ids) const;
	virtual bool getLastNodeIdQuery(int & id) const;
	virtual bool getLastWordIdQuery(int & id) const;
	virtual bool getInvertedIndexNiQuery(int signatureId, int & ni) const;
	virtual bool getHighestWeightedNodeIdsQuery(unsigned int count, std::multimap<int, int> & ids) const;

private:
	std::string queryStepNode() const;
	std::string queryStepSensor() const;
	std::string queryStepLink() const;
	std::string queryStepActuator() const;
	std::string queryStepWordsChanged() const;
	std::string queryStepKeypoint() const;
	std::string queryStepSensors() const;
	int stepNode(sqlite3_stmt * ppStmt, const Signature * s) const;
	int stepSensor(sqlite3_stmt * ppStmt, int id, int num, const std::vector<int> & data, const Sensor & sensor) const;
	int stepLink(sqlite3_stmt * ppStmt, int fromId, int toId, int type, int actuator_id, const std::vector<int> & baseIds) const;
	int stepActuator(sqlite3_stmt * ppStmt, int id, int num, const Actuator & actuator) const;
	int stepWordsChanged(sqlite3_stmt * ppStmt, int signatureId, int oldWordId, int newWordId) const;
	int stepKeypoint(sqlite3_stmt * ppStmt, int signatureId, int wordId, const cv::KeyPoint & kp) const;

private:
	int loadOrSaveDb(sqlite3 *pInMemory, const std::string & fileName, int isSave) const;

private:
	sqlite3 * _ppDb;
	bool _dbInMemory;
	unsigned int _cacheSize;
	int _journalMode;
	int _synchronous;
	int _tempStore;
};

}

#endif /* DBDRIVERSQLITE3_H_ */