|
[-]
[+]
|
Changed |
cego.changes
|
|
|
|
[-]
[+]
|
Changed |
cego.spec
^
|
|
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/README
^
|
| @@ -4,7 +4,7 @@
----
A relational and transactional database system
- Version 2.14.0
+ Version 2.14.1
(C)opyright 2006,2007,2008,2009,2010,2011,2012 by Bjoern Lemke
@@ -14,7 +14,7 @@
-----------
To build Cego, you need the following library packages available from www.lemke-it.com:
- lfc-1.3.3.tar.gz
+ lfc-1.3.4.tar.gz
lfcxml-1.0.27.tar.gz
Furthermore, you need the GNU readline library available via http://tiswww.case.edu/php/chet/readline/rltop.html
|
|
[-]
[+]
|
Added |
cego-2.14.1.tar.bz2/samples/chkdb/pid
^
|
| @@ -0,0 +1 @@
+71499
\ No newline at end of file
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/src/CegoAdmin.cc
^
|
| @@ -526,11 +526,18 @@
cout << " [t18] correct tableset <tableset>" << endl;
cout << " [t19] set checkpoint <intval> for <tableset>" << endl;
cout << " [t20] set initfile '<initfile>' for <tableset>" << endl;
- cout << " [t21] sync tableset <tableset> [ with '<command>' [ <timeout> ] ] " << endl;
- cout << " [t22] list datafile for <tableset>" << endl;
- cout << " [t23] list logfile for <tableset>" << endl;
- cout << " [t24] list transaction for <tableset>" << endl;
- cout << " [t25] list object for <tableset>" << endl;
+ cout << " [t21] set syssize <intval> for <tableset>" << endl;
+ cout << " [t22] set tmpsize <intval> for <tableset>" << endl;
+ cout << " [t23] set tsroot '<root path>' for <tableset>" << endl;
+ cout << " [t24] set tsticket '<ticket path>' for <tableset>" << endl;
+ cout << " [t25] set lognum <intval> for <tableset>" << endl;
+ cout << " [t26] set logsize <intval> for <tableset>" << endl;
+ cout << " [t27] set sortareasize <intval> for <tableset>" << endl;
+ cout << " [t28] sync tableset <tableset> [ with '<command>' [ <timeout> ] ] " << endl;
+ cout << " [t39] list datafile for <tableset>" << endl;
+ cout << " [t30] list logfile for <tableset>" << endl;
+ cout << " [t31] list transaction for <tableset>" << endl;
+ cout << " [t32] list object for <tableset>" << endl;
cout << endl;
cout << " User and role administration" << endl;
@@ -1073,10 +1080,92 @@
cout << "set initfile '<initfile>' for <tableset>" << endl;
cout << "----------------------------------------" << endl;
cout << endl;
+ cout << " Sets the specified init file for the corresponding tableset." << endl;
+ cout << " The init file must be an existing file containing database commands" << endl;
+ cout << " and must be specified with a full path." << endl;
+ cout << endl;
+ cout << " The database commands of the init file are executed at tableset startup time." << endl;
+ cout << " In this sense, an init file can be used to perform cleanup" << endl;
+ cout << " or consistency operations on user level" << endl;
+ cout << endl;
+ cout << " For example, counter values, which are not transaction safe can be adjusted" << endl;
+ cout << " to appropriate values" << endl;
+ cout << endl;
}
else if ( topic == Chain("t21"))
{
cout << endl;
+ cout << "set syssize <intval> for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the initial system page size." << endl;
+ cout << " To perform this operation, the corresponding tableset must be in status defined" << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t22"))
+ {
+ cout << endl;
+ cout << "set tmpsize <intval> for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the initial temp page size." << endl;
+ cout << " To perform this operation, the corresponding tableset must be in status defined" << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t23"))
+ {
+ cout << endl;
+ cout << "set tsroot '<tableset root path>' for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the tableset root path." << endl;
+ cout << " To perform this operation, the corresponding tableset must be in status defined" << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t24"))
+ {
+ cout << endl;
+ cout << "set tsticket '<ticket file>' for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the ticket file for the tableset online backup." << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t25"))
+ {
+ cout << endl;
+ cout << "set lognum <intval> for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the number of online redo log file for the correspoinding tableset." << endl;
+ cout << " To perform this operation, the corresponding tableset must be in status defined" << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t26"))
+ {
+ cout << endl;
+ cout << "set logsize <intval> for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the file size in bytes of the redo log files for the correspoinding tableset." << endl;
+ cout << " To perform this operation, the corresponding tableset must be in status defined" << endl;
+ cout << endl;
+
+ }
+ else if ( topic == Chain("t27"))
+ {
+ cout << endl;
+ cout << "set sortareasize <intval> for <tableset>" << endl;
+ cout << "----------------------------------------" << endl;
+ cout << endl;
+ cout << " Sets the sort area size in bytes for the corresponding tableset." << endl;
+ cout << " The sortareasize is the maximum sorting buffer, which can be allocated by a single sql query" << endl;
+ cout << " The new value ist activated when the tableset is restarted" << endl;
+ cout << endl;
+ }
+ else if ( topic == Chain("t28"))
+ {
+ cout << endl;
cout << "sync tableset <tableset> [ with '<command>' ] [ <timeout> ] ]" << endl;
cout << "-------------------------------------------------------------" << endl;
cout << endl;
@@ -1085,7 +1174,7 @@
cout << " So this can be used to create a consistent snapshot for a tableset ( e.g. with ZFS snapshot commands )" << endl;
cout << endl;
}
- else if ( topic == Chain("t22"))
+ else if ( topic == Chain("t29"))
{
cout << endl;
cout << "list datafile for <tableset>" << endl;
@@ -1095,7 +1184,7 @@
cout << endl;
}
- else if ( topic == Chain("t23"))
+ else if ( topic == Chain("t30"))
{
cout << endl;
cout << "list logfile for <tableset>" << endl;
@@ -1104,7 +1193,7 @@
cout << " List all configured datafiles for the given tableset" << endl;
cout << endl;
}
- else if ( topic == Chain("t24"))
+ else if ( topic == Chain("t31"))
{
cout << endl;
cout << "list transaction for <tableset>" << endl;
@@ -1112,7 +1201,7 @@
cout << endl;
cout << endl;
}
- else if ( topic == Chain("t25"))
+ else if ( topic == Chain("t32"))
{
cout << endl;
cout << "list object for <tableset>" << endl;
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/src/CegoAdminThread.cc
^
|
| @@ -2641,20 +2641,30 @@
{
Chain tableSet;
- Chain type;
+ Chain fileType;
Chain dataFile;
int fileSize;
int fileId;
pAH->getTableSet(tableSet);
- pAH->getFileType(type);
+ pAH->getFileType(fileType);
pAH->getFileId(fileId);
pAH->getFileName(dataFile);
pAH->getFileSize(fileSize);
- _pTabMng->addDataFile(tableSet, type, fileId, dataFile, fileSize);
+ _pTabMng->addDataFile(tableSet, fileType, fileId, dataFile, fileSize);
_pTabMng->writeCheckPoint(tableSet, true, false);
+ try
+ {
+ _pDBMng->addDataFile(tableSet, fileType, fileId, dataFile, fileSize);
+ }
+ catch ( Exception e )
+ {
+ Chain msg = e.getBaseMsg();
+ throw Exception(EXLOC, msg);
+ }
+
pAH->sendResponse(Chain("Data file " + dataFile + " added"));
}
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/src/CegoDefs.h
^
|
| @@ -40,7 +40,7 @@
#endif
#define CEGO_PRODUCT "Cego"
-#define CEGO_VERSION "2.14.0"
+#define CEGO_VERSION "2.14.1"
#define CEGO_COPYRIGHT "Copyright (C) 2000-2012 by Bjoern Lemke. All rights reserved"
/*******************************/
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/src/CegoTableManager.cc
^
|
| @@ -684,7 +684,7 @@
_pDBMng->regDataFile(tabSetId, dataFile, fileId, _pLockHandle);
}
- _pDBMng->addDataFile(tableSet, type, fileId, dataFile, fileSize);
+ // _pDBMng->addDataFile(tableSet, type, fileId, dataFile, fileSize);
}
long CegoTableManager::writeCheckPoint(const Chain& tableSet, bool switchLog, bool archComplete, const Chain& escCmd, int timeout)
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/tools/cgmkdb
^
|
| @@ -168,7 +168,7 @@
cat << _EOF_ > ${DBSTARTSCRIPT}
#!/bin/sh
echo "Starting cego database-instance:${DBNAME} with tableset:${TS} ..."
-nohup cego --mode=daemon ${MAINARGS} &
+nohup cego --mode=daemon ${MAINARGS} --pidfile=${PIDFILE} &
sleep 2
echo ""
_EOF_
|
|
[-]
[+]
|
Changed |
cego-2.14.1.tar.bz2/tools/cgmkdb~
^
|
| @@ -13,13 +13,12 @@
#
## Variable definitions:
-myVersion="2.2"; ## Helps to identify and keep track of different editions.
+myVersion="2.3"; ## Helps to identify and keep track of different editions.
DEFCEGOROOT=/usr/local/cego
-
## Function definitions:
printVersion() {
- echo "cgmkdb v${myVersion} - The cego empty database generator utility."
+ echo "cgmkdb v${myVersion} - The cego database generator utility."
}
printUsage() {
@@ -33,7 +32,6 @@
case "$1" in
-h|-\?|-help|--help) printVersion; printUsage; exit 0;;
-v|-V|--version) printVersion; echo ""; exit 0;;
- *) printVersion; echo "Incorrect use of parameter: $1."; printUsage; exit 0;;
esac
fi
@@ -123,8 +121,6 @@
### end of customizing ###
##########################
-
-
mkdir ${DBROOT}
test $? != 0 && { echo "Cannot create database root directory."; exit 1; }
|
