DS.h

Go to the documentation of this file.

/***********************************************************************

  ColorBox2: DS.h
    (c) 2004 by Martin Decky
  
  Distributed under the terms of Lesser General Public Licence, see
  COPYING.

  0.4           10th September 2004     initial

***********************************************************************/


#ifndef __CB2__DS_H__
#define __CB2__DS_H__


#include <cb2/utils.h>
#include <mysql.h>


#define CB2_MYSQL(cond, error, warning) \
    if (!(cond)) \
        throw ExceptionMySQL(ExceptionMySQL::error, warning ": " #cond " in " __FILE__, __LINE__);


namespace CB2 {
    

    typedef MapList Row;       
    typedef List< Row > Query; 
    class Domain : public Class {
        public:
            
            typedef enum {
                str_row_eq, 
                str_row_neq 
            } constrain_str_value;
            
            typedef enum {
                int_row_eq,  
                int_row_neq, 
                int_row_gt,  
                int_row_lt,  
                int_row_ge,  
                int_row_le   
            } constrain_int_value;
            
            Domain();                                                                        
            Domain(const Domain & prev);                                                     
            Domain(const constrain_str_value con, const String & key, const String & value); 
            Domain(const constrain_int_value con, const String & key, const int value);      
            ~Domain();                                                                       
            const Domain & operator&&(const Domain & right); 
            const Domain & operator||(const Domain & right); 
            const Domain & operator!();                      
            typedef enum {
                str_value, 
                int_value  
            } constrain_type;
            
            typedef struct {
                constrain_str_value con; 
                String key;              
                String value;            
            } constrain_str_value_atom;
            
            typedef struct {
                constrain_int_value con; 
                String key;              
                int value;               
            } constrain_int_value_atom;
            
            typedef struct {
                constrain_type type;                
                constrain_str_value_atom str_value; 
                constrain_int_value_atom int_value; 
            } constrain_atom;
            
            typedef List< constrain_atom> constrain_literal; 
            typedef List< constrain_literal> constrain_cnf;  
            constrain_cnf constrains; 
    };
    
    
    class DataSource : public Class {
        public:
            DataSource();              
            virtual ~DataSource() = 0; 
            virtual Query Select(const String & table, const Domain & domain, const Query::size_type limit, const Query::size_type displacement) = 0; 
    };
    
    
    class ExceptionMySQL : public Exception {
        public:

            typedef enum {
                unknown_error,    
                internal_error,   
                connection_error, 
                query_error       
            } error_type; 
            ExceptionMySQL();                                                          
            ExceptionMySQL(const error_type error, const String what);                 
            ExceptionMySQL(const error_type error, const String what, const int line); 
            error_type GetError() const; 
        private:
            
            error_type err; 
    };
    
    
    class DSMySQL : public DataSource {
        public:
            DSMySQL(const String & host, const String & user, const String & passwd, const String & db, const unsigned int port = 0, const String & socket = ""); 
            virtual ~DSMySQL();                                                                                                                                   
            Query Select(const String & table, const Domain & domain, const Query::size_type limit = 0, const Query::size_type displacement = 0); 
        private:
            
            MYSQL * handle; 
    };
    
    
    class DSFlatFile : public DataSource {
        public:
            DSFlatFile(const String & filename);
            virtual ~DSFlatFile();
            
            Query Select(const String & table, const Domain & domain, const Query::size_type limit = 0, const Query::size_type displacement = 0); 
    };
    
    
    class DSCSVFile : public DataSource {
        public:
            DSCSVFile(const String & filename);
            virtual ~DSCSVFile();
            
            Query Select(const String & table, const Domain & domain, const Query::size_type limit = 0, const Query::size_type displacement = 0); 
    };
    
    
    class DSXMLFile : public DataSource {
        public:
            DSXMLFile(const String & filename);
            virtual ~DSXMLFile();
            
            Query Select(const String & table, const Domain & domain, const Query::size_type limit = 0, const Query::size_type displacement = 0); 
    };
    
}


#endif

---