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 <string>
#include <set>
#include "litesql/types.hpp"
#include "litesql/expr.hpp"
#include "litesql/backend.hpp"
#include "litesql/cursor.hpp"
namespace litesql {
using namespace std;

class ColumnDefinition {
public:
  string name;
  string type;

  class EqualName {
    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:
    string backendType;
    string connInfo;
    Database &operator=(const Database &op);
    void openDatabase();
protected:
    Backend* backend;
    class SchemaItem {
    public:
        string name, type, sql;
        SchemaItem(const string& n, const string& t, const 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(string name, string oldSchema, string newSchema) const;

    bool addColumn(const string & name,const ColumnDefinition & column_def) const;

public:
    bool verbose;
    Database(const string& backendType, const string& connInfo);
    Database(const Database &op);
    virtual ~Database();
    void create() const;
    void drop() const;
    bool needsUpgrade() const;
    void upgrade() const;
    Records query(const string &query) const;
    template <class T> 
        Cursor<T> cursor(const string& query) const {
        if (verbose)
            cerr << query << endl;
        return Cursor<T>(*this, backend->cursor(query));
    }

    void insert(const string &table, const Record &r,
                const Split& fields=Split()) const;
    string groupInsert(Record tables, Records fields, Records values, 
                     string sequence) const;
    void delete_(const string &table, const Expr& e= Expr()) const; 
    void begin() const { backend->begin(); }
    void commit() const { backend->commit(); }
    void rollback() const { backend->rollback(); }  
};

}

#endif