database.hpp

Go to the documentation of this file.

/* LiteSQL 
 * 
 * The list of contributors at http://litesql.sf.net/ 
 * 
 * See LICENSE for copyright information. */
 
#ifndef litesql_database_hpp
#define litesql_database_hpp
 
#include "litesql/expr.hpp"
#include "litesql/cursor.hpp"
 
namespace litesql {
 
class ColumnDefinition {
public:
  std::string name;
  std::string type;
 
  class EqualName {
    std::string m_name;
  public: 
    EqualName(const std::string& name) : m_name(name) {};
    bool operator()(ColumnDefinition d) { return d.name==m_name;};
  };
};
 
class Database {    
  friend class Updater;
private:
    std::string backendType;
    std::string connInfo;
    Database &operator=(const Database &op)=delete;
    void openDatabase() noexcept(false);
protected:
    std::unique_ptr<Backend> backend;
    class SchemaItem {
    public:
        std::string name, type, sql;
        SchemaItem(const std::string& n, const std::string& t, const std::string& s) 
            : name(n), type(t), sql(s) {}
    };
    void storeSchemaItem(const SchemaItem& s) const;
    virtual std::vector<SchemaItem> getSchema() const { 
        return std::vector<SchemaItem>(); 
    }
    std::vector<SchemaItem> getCurrentSchema() const;
    void upgradeTable(const std::string& name, const std::string& oldSchema, const std::string& newSchema) const;
 
    bool addColumn(const std::string & name,const ColumnDefinition & column_def) const;
 
public:
   bool verbose;
    Database(const std::string& backendType, const std::string& connInfo);
    Database(const Database &op);
    virtual ~Database();
    void create() const;
    void drop() const;
    bool needsUpgrade() const;
    void upgrade() const;
    Records query(const std::string &query) const;
    template <class T> 
        Cursor<T> cursor(const std::string& query) const {
        if (verbose)
            std::cerr << query << std::endl;
        return Cursor<T>(*this, backend->cursor(query));
    }
 
    void insert(const std::string &table, const Record &r,
                const std::vector<std::string>& fields=std::vector<std::string>()) const;
    std::string groupInsert(const Record& tables, 
                       const Records& fields, 
                       const Records& values, 
                       const std::string& sequence) const;
    void delete_(const std::string &table, const Expr& e= Expr()) const; 
    void begin() const { backend->begin(); }
    void commit() const { backend->commit(); }
    void rollback() const { backend->rollback(); }  
};
 
}
 
#endif