name changes

oamapps/columnstoreDB/columnstoreDB.cpp

@@ -0,0 +1,154 @@
+/* Copyright (C) 2014 Columnstore, Inc.
+
+   This program is free software; you can redistribute it and/or
+   modify it under the terms of the GNU General Public License
+   as published by the Free Software Foundation; version 2 of
+   the License.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+   MA 02110-1301, USA. */
+
+/******************************************************************************************
+ * $Id: columnstoreDB.cpp 419 2007-07-22 17:18:00Z dhill $
+ *
+ ******************************************************************************************/
+/**
+ * @file
+ */
+
+#include <iostream>
+#include <fstream>
+#include <cstdlib>
+#include <string>
+#include <limits.h>
+#include <sstream>
+#include <exception>
+#include <stdexcept>
+#include <vector>
+#include <stdio.h>
+#include <ctype.h>
+#include <sys/signal.h>
+#include <sys/types.h>
+
+#include "liboamcpp.h"
+#include "configcpp.h"
+#include "installdir.h"
+
+using namespace std;
+using namespace oam;
+using namespace config;
+
+namespace {
+
+void usage(char *prog)
+{
+
+	cout << endl;
+	cout << "Usage: " << prog << " [options]" << endl;
+
+	cout << endl;
+	cout << "This utility is used to suspend and resume Columnstore Database Writes." << endl;
+	cout << "Normally this would be done while performing Database Backups and" << endl;
+	cout << "Restores " << endl;
+	cout << endl;
+
+	cout << "Options:" << endl;
+	cout << "-c <command>   Command: suspend or resume" << endl << endl;
+	cout << "-h             Display this help." << endl << endl;
+}
+}
+
+int main(int argc, char **argv)
+{
+	string command;
+	Oam oam;
+	BRM::DBRM dbrm;
+
+	char c;
+	
+	// Invokes member function `int operator ()(void);'
+	while ((c = getopt(argc, argv, "c:h")) != -1) {
+		switch (c) {  
+			case 'c': 
+				command = optarg;
+				break;
+			case 'h':
+				usage(argv[0]);
+				exit(-1);
+				break;
+			default: 
+				usage(argv[0]);
+				exit(1);
+				break;
+		}
+	}
+
+	if ( command == "suspend" ) 
+	{
+		try
+		{
+            std::vector<BRM::TableLockInfo> tableLocks = dbrm.getAllTableLocks();
+            if (!tableLocks.empty())
+            {
+                oam.DisplayLockedTables(tableLocks, &dbrm);
+            }
+			else
+			{
+				dbrm.setSystemSuspended(true);
+				sleep(5);
+				string cmd = startup::StartUp::installDir() + "/bin/save_brm  > /var/log/MariaDB/Columnstore/save_brm.log1 2>&1";
+				int rtnCode = system(cmd.c_str());
+				if (rtnCode == 0)
+				{
+					cout << endl << "Suspend Columnstore Database Writes Request successfully completed" << endl;
+				}
+				else
+				{
+					cout << endl << "Suspend Columnstore Database Writes Failed: save_brm Failed" << endl;
+					dbrm.setSystemSuspended(false);
+				}
+			}
+		}
+		catch (exception& e)
+		{
+			cout << endl << "**** Suspend Columnstore Database Writes Failed: " << e.what() << endl;
+		}
+		catch(...)
+		{
+			cout << endl << "**** Suspend Columnstore Database Writes Failed" << endl;
+		}
+	}
+	else
+	{
+		if ( command == "resume" ) 
+		{
+			try{
+				dbrm.setSystemSuspended(false);
+				cout << endl << "Resume Columnstore Database Writes Request successfully completed" << endl;
+			}
+			catch (exception& e)
+			{
+				cout << endl << "**** Resume Columnstore Database Writes Failed: " << e.what() << endl;
+			}
+			catch(...)
+			{
+				cout << endl << "**** Resume Columnstore Database Writes Failed" << endl;
+			}
+		}
+		else
+		{
+			cout << "Invalid Command Entered, please try again" << endl;
+			exit(-1);
+		}
+	}
+
+	exit(0);
+}
+