Thread portable class Gate portable class Timer class Pool class Terimber 2.0 About C++

Downloads Products & Services Support Clients Open Source About Home / Open source / Terimber 2.0 memdb.h Go to the documentation of this file. /* * The Software License * ================================================================================= * Copyright (c) 2003-.The Terimber Corporation. All rights reserved. * ================================================================================= * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * The end-user documentation included with the redistribution, if any, * must include the following acknowledgment: * "This product includes software developed by the Terimber Corporation." * ================================================================================= * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE TERIMBER CORPORATION OR ITS CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ================================================================================ */ #ifndef _terimber_memdb_h_ #define _terimber_memdb_h_ #include "db/db.h" #include "memdb/memdbacc.h" #include "base/vector.h" #include "base/list.h" #include "base/map.h" #include "base/common.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) class terimber_index_column_info_ex : public terimber_index_column_info { public: dbtypes _type; }; class terimber_db_value_vector_impl : public terimber_db_value_vector { public: terimber_db_value_vector_impl(size_t count ); virtual ~terimber_db_value_vector_impl(); virtual size_t get_size() const; virtual bool set_value_as_null(size_t index, dbtypes type ); virtual bool set_value_as_bool(size_t index, bool val ); virtual bool set_value_as_char(size_t index, sb1_t val ); virtual bool set_value_as_byte(size_t index, ub1_t val ); virtual bool set_value_as_short(size_t index, sb2_t val ); virtual bool set_value_as_word(size_t index, ub2_t val ); virtual bool set_value_as_long(size_t index, sb4_t val ); virtual bool set_value_as_dword(size_t index, ub4_t val ); virtual bool set_value_as_float(size_t index, float val ); virtual bool set_value_as_double(size_t index, double val ); virtual bool set_value_as_long64(size_t index, sb8_t val ); virtual bool set_value_as_dword64(size_t index, ub8_t val ); virtual bool set_value_as_guid(size_t index, const guid_t& val ); // this function depends on format // to avoid the confusions of different numeric and date formats // -1223456.7894 - delimeter here is "." // -1223456,7894 - delimeter here is "," virtual bool set_value_as_numeric(size_t index, const char* val, char delimeter ); virtual bool set_value_as_decimal(size_t index, const char* val, char delimeter ); // date from A.C. year > 0 // valid input // year [1000000] // // // // // // millisec [0 - 999] virtual bool set_value_as_date(size_t index, ub4_t year, ub1_t month, ub1_t day, ub1_t hour, ub1_t minute, ub1_t second, ub2_t millisec ); virtual bool set_value_as_string(size_t index, const char* val, size_t len ); virtual bool set_value_as_string_ptr(size_t index, const char* val ); virtual bool set_value_as_wstring(size_t index, const wchar_t* val, size_t len ); virtual bool set_value_as_wstring_ptr(size_t index, const wchar_t* val ); virtual bool set_value_as_binary(size_t index, const ub1_t* val, size_t len ); virtual bool set_value_as_binary_ptr(size_t index, const ub1_t* val ); virtual bool get_value_is_null(size_t index ) const; virtual bool get_value_as_bool(size_t index ) const; virtual sb1_t get_value_as_char(size_t index ) const; virtual ub1_t get_value_as_byte(size_t index ) const; virtual sb2_t get_value_as_short(size_t index ) const; virtual ub2_t get_value_as_word(size_t index ) const; virtual sb4_t get_value_as_long(size_t index ) const; virtual ub4_t get_value_as_dword(size_t index ) const; virtual float get_value_as_float(size_t index ) const; virtual double get_value_as_double(size_t index ) const; virtual sb8_t get_value_as_long64(size_t index ) const; virtual ub8_t get_value_as_dword64(size_t index ) const; virtual bool get_value_as_guid(size_t index, guid_t& val ) const; // delimeter defines the desirable delimeter sign virtual const char* get_value_as_numeric(size_t index, char delimeter ) const; // delimeter defines the desirable delimeter sign virtual const char* get_value_as_decimal(size_t index, char delimeter ) const; // to avoid confusions with different date formats, functions return parsed date virtual bool get_value_as_date(size_t index, ub4_t& year, ub1_t& month, ub1_t& day, ub1_t& hour, ub1_t& minute, ub1_t& second, ub2_t& millisec, ub1_t& wday, ub2_t& yday ) const; virtual const char* get_value_as_string(size_t index ) const; virtual const wchar_t* get_value_as_wstring(size_t index ) const; virtual const ub1_t* get_value_as_binary(size_t index, size_t& len ) const; virtual const ub1_t* get_value_as_binary_ptr(size_t index ) const; private: terimber_xml_value get_value_as_value(size_t index, vt_types type ) const; public: mutable byte_allocator _tmp_allocator; vector< binder > _value; }; class memdb_row { public: _vector< terimber_db_value > _row; terimber_db_row_status _status; }; typedef list< memdb_row > memdb_rowset_t; typedef memdb_rowset_t::iterator memdb_rowset_iterator_t; typedef memdb_rowset_t::const_iterator memdb_rowset_citerator_t; typedef vector< terimber_index_column_info_ex > terimber_index_column_array_t; static inline int compare_db_value( dbtypes type, const terimber_db_value& first, const terimber_db_value second, bool case_insensitive ); class memdb_rowset_less { public: memdb_rowset_less(const terimber_index_column_array_t& info ) : _info(info) { } inline bool operator()(const memdb_rowset_citerator_t& first, const memdb_rowset_citerator_t& second) const; inline const terimber_index_column_array_t& get_info() const { return _info; } private: terimber_index_column_array_t _info; }; typedef map< memdb_rowset_citerator_t, memdb_rowset_citerator_t, memdb_rowset_less, true > memdb_index_t; typedef memdb_index_t::const_iterator memdb_index_citer_t; // forward declaration class memindex; class memlookup; class memtable : public terimber_memtable { typedef list< memindex* > list_indexes_t; typedef list< terimber_db_value_vector_impl* > list_values_t; public: memtable(); virtual ~memtable(); virtual const char* get_last_error(); virtual bool populate( dbserver* server, size_t start_row, size_t max_rows ); virtual bool create( size_t columns, const terimber_table_column_desc desc[] ); virtual void refresh(); virtual size_t get_row_count(); virtual size_t get_column_count() const; virtual dbtypes get_column_type(size_t index ) const; virtual const char* get_column_name(size_t index ) const; virtual bool get_column_nullable(size_t index ) const; virtual size_t get_column_scale(size_t index ) const; virtual size_t get_column_precision(size_t index ) const; virtual size_t get_column_max_length(size_t index ) const; virtual terimber_memindex* add_index( size_t columns, const terimber_index_column_info info[] ); virtual bool remove_index( terimber_memindex* obj ); virtual terimber_db_value_vector* allocate_db_values(size_t count ); virtual void destroy_db_values(terimber_db_value_vector* obj ); public: inline const memdb_rowset_t& get_rowset() const { return _rowset; } inline const binders_t& get_cols() const { return _cols; } bool insert_row( const terimber_db_value_vector* info ); bool update_row( memdb_rowset_citerator_t iter, const terimber_db_value_vector* info ); bool delete_row( memdb_rowset_citerator_t iter ); private: void uninit(); private: byte_allocator _allocator; binders_t _cols; memdb_rowset_t _rowset; string_t _error; mutex _mtx; list_indexes_t _indexes; list_values_t _values; }; class memindex : public terimber_memindex, public terimber_log_helper { friend class memtable; typedef list< memlookup* > list_lookups_t; protected: memindex( memtable& parent, const memdb_rowset_less& pred ); virtual ~memindex(); public: virtual terimber_memlookup* add_lookup( const terimber_db_value_vector* info ); virtual bool remove_lookup( terimber_memlookup* obj ); public: inline const memtable& get_table() const { return _parent; } inline memtable& get_table() { return _parent; } inline const memdb_index_t& get_index() { return _index; } private: bool construct(); void notify( memdb_rowset_citerator_t iter, bool insert_or_delete ); private: memtable& _parent; memdb_index_t _index; mutex _mtx; list_lookups_t _lookups; }; class memlookup : public terimber_memlookup, public terimber_log_helper { friend class memindex; protected: memlookup( memindex& parent ); virtual ~memlookup(); bool construct( const terimber_db_value_vector_impl* info ); public: virtual bool assign( const terimber_memlookup& x ); virtual bool reset( const terimber_db_value_vector* info ); virtual bool next() const; virtual bool prev() const; virtual bool get_value_is_null(size_t index ) const; virtual bool get_value_as_bool(size_t index ) const; virtual sb1_t get_value_as_char(size_t index ) const; virtual ub1_t get_value_as_byte(size_t index ) const; virtual sb2_t get_value_as_short(size_t index ) const; virtual ub2_t get_value_as_word(size_t index ) const; virtual sb4_t get_value_as_long(size_t index ) const; virtual ub4_t get_value_as_dword(size_t index ) const; virtual float get_value_as_float(size_t index ) const; virtual double get_value_as_double(size_t index ) const; virtual sb8_t get_value_as_long64(size_t index ) const; virtual ub8_t get_value_as_dword64(size_t index ) const; virtual bool get_value_as_guid(size_t index, guid_t& val ) const; virtual const char* get_value_as_numeric(size_t index, char delimeter ) const; virtual const char* get_value_as_decimal(size_t index, char delimeter ) const; virtual bool get_value_as_date(size_t index, ub4_t& year, ub1_t& month, ub1_t& day, ub1_t& hour, ub1_t& minute, ub1_t& second, ub2_t& millisec, ub1_t& wday, ub2_t& yday ) const; virtual const char* get_value_as_string(size_t index ) const; virtual const wchar_t* get_value_as_wstring(size_t index ) const; virtual const ub1_t* get_value_as_binary(size_t index, size_t& len ) const; virtual const ub1_t* get_value_as_binary_ptr(size_t index ) const; virtual bool insert_row( const terimber_db_value_vector* info ); virtual bool delete_row(); virtual bool update_row( const terimber_db_value_vector* info ); virtual terimber_db_row_status get_row_status(); private: void notify( memdb_index_citer_t iter, bool insert_or_delete ); terimber_xml_value get_value_as_value(size_t index, vt_types type ) const; private: mutable byte_allocator _tmp_allocator; memindex& _parent; memdb_index_citer_t _low_bounder; memdb_index_citer_t _upper_bounder; mutable memdb_index_citer_t _current_iter; byte_allocator _condition_allocator; memdb_rowset_t _condition_rowset; }; #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_memdb_h_

© Copyright Terimber 2003-.