Update README.md

README.md

@@ -9,4 +9,92 @@
 * error-handling 
 
        to provide a means of recovering from failed operations and other problems.
+       
+* cluster
+
+
+      int main(int argc, char** argv)
+      {
+        if (argc != 3)
+        {
+          std::cout << "Arguments are <socket mysqld> <connect_string cluster>.\n";
+          exit(-1);
+        }
+        char * mysqld_sock  = argv[1];
+        const char *connection_string = argv[2];
+        ndb_init();
+
+        Ndb_cluster_connection *cluster_connection=
+          new Ndb_cluster_connection(connection_string); // Object representing the cluster
+
+        int r= cluster_connection->connect(5 /* retries               */,
+               3 /* delay between retries */,
+               1 /* verbose               */);
+        if (r > 0)
+        {
+          std::cout
+            << "Cluster connect failed, possibly resolved with more retries.\n";
+          exit(-1);
+        }
+        else if (r < 0)
+        {
+          std::cout
+            << "Cluster connect failed.\n";
+          exit(-1);
+        }
+
+        if (cluster_connection->wait_until_ready(30,30))
+        {
+          std::cout << "Cluster was not ready within 30 secs." << std::endl;
+          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", "", "",
+            0, mysqld_sock, 0) )
+          MYSQLERROR(mysql);
+
+        /********************************************
+         * Connect to database via mysql-c          *
+         ********************************************/
+        mysql_query(&mysql, "CREATE DATABASE ndb_examples");
+        if (mysql_query(&mysql, "USE ndb_examples") != 0) MYSQLERROR(mysql);
+        create_table(mysql);
+
+        Ndb* myNdb= new Ndb( cluster_connection,
+               "ndb_examples" );  // Object representing the database
+
+        if (myNdb->init() == -1) {
+          APIERROR(myNdb->getNdbError());
+          exit(-1);
+        }
+
+        const NdbDictionary::Dictionary* myDict= myNdb->getDictionary();
+        const NdbDictionary::Table *myTable= myDict->getTable("api_retries");
+        if (myTable == NULL)
+        {
+          APIERROR(myDict->getNdbError());
+          return -1;
+        }
+        /************************************
+         * Execute some insert transactions *
+         ************************************/
+
+        std::cout << "Ready to insert rows.  You will see notices for temporary "
+          "errors, permenant errors, and retries. \n";
+        for (int i = 10000; i < 20000; i++) {
+          executeInsertTransaction(i, myNdb, myTable);
+        }
+        std::cout << "Done.\n";
+
+        delete myNdb;
+        delete cluster_connection;
+
+        ndb_end(0);
+        return 0;
+      }