|
[-]
[+]
|
Changed |
cego.changes
|
|
|
|
[-]
[+]
|
Changed |
cego.spec
^
|
|
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/README
^
|
| @@ -4,7 +4,7 @@
----
A relational and transactional database system
- Version 2.10.6
+ Version 2.10.7
(C)opyright 2006,2007,2008,2009,2010,2011 by Bjoern Lemke
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/TODO
^
|
| @@ -5,3 +5,4 @@
Manage append mode also for distributed queries
Idea : With session request append mode is set up
+- read performance can be improved by replacing XML protocol by native encoding model
|
|
[-]
[+]
|
Added |
cego-2.10.7.tar.bz2/TODO~
^
|
| @@ -0,0 +1,7 @@
+In CegoAction, make the following distribution ready
+- show systemspace
+- check index
+- create, list set, drop counter
+Manage append mode also for distributed queries
+Idea : With session request append mode is set up
+
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoDbThread.cc
^
|
| @@ -212,11 +212,10 @@
{
Chain tableSet = _pDBMng->getTabSetName(tabSetId);
- CegoAction* pPA = new CegoAction(_pTabMng);
try
{
- pPA->setTableSet(tableSet);
+ _pPA->setTableSet(tableSet);
ListT<Chain> procList;
_pTabMng->getObjectList(tabSetId, CegoObject::PROCEDURE, procList);
@@ -233,11 +232,11 @@
_pDBMng->log(_modId, Logger::DEBUG, Chain("Thread ") + Chain(_idx) + Chain(" : Loading <<< ") + loadString + Chain(">>>"));
- pPA->cleanUp();
- pPA->setCommandChain(loadString);
- pPA->parse();
+ _pPA->cleanUp();
+ _pPA->setCommandChain(loadString);
+ _pPA->parse();
- CegoProcedure* pProc = pPA->getProcedure();
+ CegoProcedure* pProc = _pPA->getProcedure();
_pTabMng->addCompProcedure(tabSetId, pProc);
_pDBMng->log(_modId, Logger::DEBUG, Chain("Thread ") + Chain(_idx) + Chain(" : Procedure ") + *pProcName + Chain(" added"));
@@ -259,11 +258,11 @@
_pDBMng->log(_modId, Logger::DEBUG, Chain("Thread ") + Chain(_idx) + Chain(" : Loading <<< ") + loadString + Chain(">>>"));
- pPA->cleanUp();
- pPA->setCommandChain(loadString);
- pPA->parse();
+ _pPA->cleanUp();
+ _pPA->setCommandChain(loadString);
+ _pPA->parse();
- CegoSelect* pSelect = pPA->getSelect();
+ CegoSelect* pSelect = _pPA->getSelect();
CegoView *pView = new CegoView(*pViewName, pSelect);
@@ -273,13 +272,10 @@
pViewName = viewList.Next();
}
- delete pPA;
-
}
catch ( Exception e )
{
- delete pPA;
Chain msg = Chain("Cannot load objects");
throw Exception(EXLOC, msg, e);
}
@@ -315,6 +311,7 @@
}
}
+/*
void CegoDbThread::loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type)
{
@@ -387,6 +384,7 @@
throw e;
}
}
+*/
void CegoDbThread::serveSession(CegoDistDbHandler *pSH)
{
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoDbThread.h
^
|
| @@ -64,7 +64,7 @@
void loadObjects(int tabSetId);
void unloadObjects(int tabSetId);
void invalidateObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
- void loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
+ // void loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
void addReloadRequest(int tabSetId);
void checkReloadRequest();
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoDbThreadPool.cc
^
|
| @@ -216,6 +216,7 @@
}
}
+/*
void CegoDbThreadPool::loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type)
{
int i=0;
@@ -225,6 +226,7 @@
i++;
}
}
+*/
int CegoDbThreadPool::getPoolLimit() const
{
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoDbThreadPool.h
^
|
| @@ -62,7 +62,7 @@
void loadObjects(int tabSetId);
void unloadObjects(int tabSetId);
void invalidateObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
- void loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
+ // void loadObject(int tabSetId, const Chain& objName, CegoObject::ObjectType type);
int getPoolLimit() const;
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoDefs.h
^
|
| @@ -40,7 +40,7 @@
#endif
#define CEGO_PRODUCT "Cego"
-#define CEGO_VERSION "2.10.6"
+#define CEGO_VERSION "2.10.7"
#define CEGO_COPYRIGHT "Copyright (C) 2000-2011 by Bjoern Lemke. All rights reserved"
/*******************************/
|
|
[-]
[+]
|
Changed |
cego-2.10.7.tar.bz2/src/CegoXPorter.cc
^
|
| @@ -616,8 +616,8 @@
_pGTM->createDistView(tableSet, viewName, fl, viewStmt);
- if ( _pDbPool )
- _pDbPool->loadObject(tabSetId, viewName, CegoObject::VIEW);
+ // if ( _pDbPool )
+ // _pDbPool->loadObject(tabSetId, viewName, CegoObject::VIEW);
}
@@ -635,8 +635,8 @@
_pGTM->createDistProc(tableSet, procName, procText);
- if ( _pDbPool )
- _pDbPool->loadObject(tabSetId, procName, CegoObject::PROCEDURE);
+ // if ( _pDbPool )
+ // _pDbPool->loadObject(tabSetId, procName, CegoObject::PROCEDURE);
pProcElement = procList.Next();
}
@@ -1834,11 +1834,12 @@
_pDBMng->log(_modId, Logger::NOTICE, Chain("Creating view ") + viewName + Chain("..."));
_pGTM->createDistView(tableSet, viewName, viewSchema, viewStmt);
- if ( _pDbPool )
- {
- int tabSetId = _pDBMng->getTabSetId(tableSet);
- _pDbPool->loadObject(tabSetId, viewName, CegoObject::VIEW);
- }
+
+ // if ( _pDbPool )
+ // {
+ // int tabSetId = _pDBMng->getTabSetId(tableSet);
+ // _pDbPool->loadObject(tabSetId, viewName, CegoObject::VIEW);
+ // }
}
@@ -1867,11 +1868,11 @@
_pGTM->createDistProc(tableSet, procName, procText);
- if ( _pDbPool )
- {
- int tabSetId = _pDBMng->getTabSetId(tableSet);
- _pDbPool->loadObject(tabSetId, procName, CegoObject::PROCEDURE);
- }
+ // if ( _pDbPool )
+ // {
+ // int tabSetId = _pDBMng->getTabSetId(tableSet);
+ // _pDbPool->loadObject(tabSetId, procName, CegoObject::PROCEDURE);
+ // }
pInFile->readByte((char*)&_tag, sizeof(BinTag));
}
|
