updated example1 to use mysql c-api for table creation (3410ce09) · Commits · Software / OSDI20 Artifacts / mariadb

ndb/examples/ndbapi_example1/Makefile

+10 −8

Original line number	Diff line number	Diff line
		TARGET = ndbapi_example1
		SRCS = ndbapi_example1.cpp
		OBJS = ndbapi_example1.o
		SRCS = $(TARGET).cpp
		OBJS = $(TARGET).o
		CXX = g++
		CFLAGS = -c -Wall -fno-rtti -fno-exceptions
		CXXFLAGS =
		DEBUG =
		LFLAGS = -Wall
		INCLUDE_DIR = ../../include
		LIB_DIR = -L../../src/.libs \
		-L../../../libmysql_r/.libs \
		-L../../../mysys
		TOP_SRCDIR = ../../..
		INCLUDE_DIR = $(TOP_SRCDIR)
		LIB_DIR = -L$(TOP_SRCDIR)/ndb/src/.libs \
		-L$(TOP_SRCDIR)/libmysql_r/.libs \
		-L$(TOP_SRCDIR)/mysys
		SYS_LIB =

		$(TARGET): $(OBJS)
		$(CXX) $(LFLAGS) $(LIB_DIR) $(OBJS) -lndbclient -lmysqlclient_r -lmysys -lz $(SYS_LIB) -o $(TARGET)
		$(CXX) $(CXXFLAGS) $(LFLAGS) $(LIB_DIR) $(OBJS) -lndbclient -lmysqlclient_r -lmysys -lz $(SYS_LIB) -o $(TARGET)

		$(TARGET).o: $(SRCS)
		$(CXX) $(CFLAGS) -I$(INCLUDE_DIR) -I$(INCLUDE_DIR)/ndbapi $(SRCS)
		$(CXX) $(CFLAGS) -I$(INCLUDE_DIR)/include -I$(INCLUDE_DIR)/ndb/include -I$(INCLUDE_DIR)/ndb/include/ndbapi $(SRCS)

		clean:
		rm -f *.o $(TARGET)

ndb/examples/ndbapi_example1/ndbapi_example1.cpp

+70 −63

Original line number	Diff line number	Diff line
		@@ -14,36 +14,50 @@
		along with this program; if not, write to the Free Software
		Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */

		//
		// ndbapi_example1.cpp: Using synchronous transactions in NDB API
		//
		// Correct output from this program is:
		//
		// ATTR1 ATTR2
		// 0 10
		// 1 1
		// 2 12
		// Detected that deleted tuple doesn't exist!
		// 4 14
		// 5 5
		// 6 16
		// 7 7
		// 8 18
		// 9 9
		/*
		* ndbapi_example1.cpp: Using synchronous transactions in NDB API
		*
		* Correct output from this program is:
		*
		* ATTR1 ATTR2
		* 0 10
		* 1 1
		* 2 12
		* Detected that deleted tuple doesn't exist!
		* 4 14
		* 5 5
		* 6 16
		* 7 7
		* 8 18
		* 9 9
		*
		*/

		#include <mysql.h>
		#include <NdbApi.hpp>
		// Used for cout
		#include <stdio.h>
		#include <iostream>

		static void run_application(Ndb_cluster_connection &);
		static void run_application(MYSQL &, Ndb_cluster_connection &);

		#define PRINT_ERROR(code,msg) \
		std::cout << "Error in " << __FILE__ << ", line: " << __LINE__ \
		<< ", code: " << code \
		<< ", msg: " << msg << "." << std::endl
		#define MYSQLERROR(mysql) { \
		PRINT_ERROR(mysql_errno(&mysql),mysql_error(&mysql)); \
		exit(-1); }
		#define APIERROR(error) { \
		PRINT_ERROR(error.code,error.message); \
		exit(-1); }

		int main()
		{
		// ndb_init must be called first
		ndb_init();

		// connect to cluster and run application
		// connect to mysql server and cluster and run application
		{
		// Object representing the cluster
		Ndb_cluster_connection cluster_connection;
		@@ -64,31 +78,47 @@ int main()
		exit(-1);
		}

		// connect to mysql server
		MYSQL mysql;
		if ( !mysql_init(&mysql) ) {
		std::cout << "mysql_init failed\n";
		exit(-1);
		}
		if ( !mysql_real_connect(&mysql, "localhost", "root", "", "",
		3306, "/tmp/mysql.sock", 0) )
		MYSQLERROR(mysql);

		// run the application code
		run_application(cluster_connection);
		run_application(mysql, cluster_connection);
		}

		// ndb_end should not be called until all "Ndb" objects are deleted
		ndb_end(0);

		std::cout << "\nTo drop created table use:\n"
		<< "echo \"drop table MYTABLENAME\" \| mysql TEST_DB_1 -u root\n";

		return 0;
		}

		#define APIERROR(error) \
		{ std::cout << "Error in " << __FILE__ << ", line:" << __LINE__ << ", code:" \
		<< error.code << ", msg: " << error.message << "." << std::endl; \
		exit(-1); }

		static void create_table(Ndb &myNdb);
		static void do_insert(Ndb &myNdb);
		static void do_update(Ndb &myNdb);
		static void do_delete(Ndb &myNdb);
		static void do_read(Ndb &myNdb);
		static void create_table(MYSQL &);
		static void do_insert(Ndb &);
		static void do_update(Ndb &);
		static void do_delete(Ndb &);
		static void do_read(Ndb &);

		static void run_application(Ndb_cluster_connection &cluster_connection)
		static void run_application(MYSQL &mysql,
		Ndb_cluster_connection &cluster_connection)
		{
		/********************************************
		* Connect to database *
		* Connect to database via mysql-c *
		********************************************/
		mysql_query(&mysql, "CREATE DATABASE TEST_DB_1");
		if (mysql_query(&mysql, "USE TEST_DB_1") != 0) MYSQLERROR(mysql);
		create_table(mysql);

		/********************************************
		* Connect to database via NdbApi *
		********************************************/
		// Object representing the database
		Ndb myNdb( &cluster_connection, "TEST_DB_1" );
		@@ -97,7 +127,6 @@ static void run_application(Ndb_cluster_connection &cluster_connection)
		/*
		* Do different operations on database
		*/
		create_table(myNdb);
		do_insert(myNdb);
		do_update(myNdb);
		do_delete(myNdb);
		@@ -107,37 +136,15 @@ static void run_application(Ndb_cluster_connection &cluster_connection)
		/*********************************************************
		* Create a table named MYTABLENAME if it does not exist *
		*********************************************************/
		static void create_table(Ndb &myNdb)
		static void create_table(MYSQL &mysql)
		{
		NdbDictionary::Dictionary* myDict = myNdb.getDictionary();

		if (myDict->getTable("MYTABLENAME") != NULL) {
		std::cout
		<< "NDB already has example table: MYTABLENAME.\n"
		<< "Use ndb_drop_table -d TEST_DB_1 MYTABLENAME\n";
		exit(-1);
		}

		NdbDictionary::Table myTable;
		NdbDictionary::Column myColumn;

		myTable.setName("MYTABLENAME");

		myColumn.setName("ATTR1");
		myColumn.setType(NdbDictionary::Column::Unsigned);
		myColumn.setLength(1);
		myColumn.setPrimaryKey(true);
		myColumn.setNullable(false);
		myTable.addColumn(myColumn);

		myColumn.setName("ATTR2");
		myColumn.setType(NdbDictionary::Column::Unsigned);
		myColumn.setLength(1);
		myColumn.setPrimaryKey(false);
		myColumn.setNullable(false);
		myTable.addColumn(myColumn);

		if (myDict->createTable(myTable) == -1) APIERROR(myDict->getNdbError());
		if (mysql_query(&mysql,
		"CREATE TABLE"
		" MYTABLENAME"
		" (ATTR1 INT UNSIGNED PRIMARY KEY,"
		" ATTR2 INT UNSIGNED)"
		" ENGINE=NDB"))
		MYSQLERROR(mysql);
		}

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