Add support for MySQL databases

Author: ibmmqmet

CHANGES.md

@@ -80,3 +80,8 @@ Jun 2018 (v4.2.0)
 
 Jul 2018 (v4.3.0)
 * Add command for converting VBS dataset to USS on z/OS
+
+Oct 2018 (v5.0.0)
+* Add instructions for MySQL importing
+* (Breaking) Modify a few column names for MySQL compatibility
+* Update for MQ V9.1.1

bin/aix/convH

@@ -19,23 +19,23 @@ void printQMST(qmst *p)
 {
   SMFPRINTSTART("QMST", p, conv16(p->qmstll));
 
-  ADDS32("Open",p->qmstopen);
-  ADDS32("Close",p->qmstclos);
-  ADDS32("Get ",p->qmstget );
-  ADDS32("Put" ,p->qmstput );
-  ADDS32("Put1",p->qmstput1);
-  ADDS32("Inq ",p->qmstinq );
+  ADDS32("MQOpen",p->qmstopen);
+  ADDS32("MQClose",p->qmstclos);
+  ADDS32("MQGet ",p->qmstget );
+  ADDS32("MQPut" ,p->qmstput );
+  ADDS32("MQPut1",p->qmstput1);
+  ADDS32("MQInq ",p->qmstinq );
   ADDS32("Inql",p->qmstinql);
-  ADDS32("Set ",p->qmstset );
+  ADDS32("MQSet ",p->qmstset );
   ADDS32("Endw",p->qmstendw);
   ADDS32("Close_Handles",p->qmstcalh);
   if (conv16(p->qmstll) >  offsetof(qmst,  qmstsub))/* Fields added for V7.0 API calls*/
   {
-    ADDS32("Sub"   ,p->qmstsub);
-    ADDS32("SubReq",p->qmstsubr);
-    ADDS32("CB  "  ,p->qmstcb);
-    ADDS32("CTL "  ,p->qmstctl);
-    ADDS32("Status",p->qmststus);
+    ADDS32("MQSub"   ,p->qmstsub);
+    ADDS32("MQSubReq",p->qmstsubr);
+    ADDS32("MQCB  "  ,p->qmstcb);
+    ADDS32("MQCTL "  ,p->qmstctl);
+    ADDS32("MQStatus",p->qmststus);
     ADDS32("Pubs"  ,p->qmstpubs);
   }
 #if CSQDSMF_VERSION >= 903

bin/aix/mqsmfcsv

@@ -46,8 +46,8 @@ void printWQ(wq *p)
   /*--------------------------------------------------------*/
   /* Object information                                     */
   /*--------------------------------------------------------*/
-  ADDSTR("Type" ,strMQQT(conv32(p->qtype)),16);
-  ADDSTR("Index",strMQIT(conv32(p->indxtype)),16);
+  ADDSTR("QueueType" ,strMQQT(conv32(p->qtype)),16);
+  ADDSTR("IndexType",strMQIT(conv32(p->indxtype)),16);
   ADDSTR("Scope",strMQQSGD(conv32(p->qsgdisp)),16);
 
   /*--------------------------------------------------------*/

bin/linux/convH

@@ -111,7 +111,7 @@ void closeDDL(char *name)
     {
       char *c = indexSet[i];
       if (c) {
-        fprintf(fp,"CREATE INDEX %s.%s_%s ON %s.%s(%s);\n",schema,name,c,schema,name,c);
+        fprintf(fp,"CREATE INDEX %s_%s ON %s.%s(%s);\n",name,c,schema,name,c);
       }
     }
     fprintf(fp,"\n");

bin/linux/mqsmfcsv

@@ -0,0 +1,41 @@
+# This script is an example of how to populate a Db2 database
+#
+# You will need to modify variables such as where the formatted csv files
+# have been created, and which database/schema to work with.
+
+# Where are the output files
+cd /tmp/smf/out
+chmod a+rx .
+
+# Set up the environment for the db2 command
+ . /home/db2inst3/sqllib/db2profile
+export LIBPATH=/opt/freeware/lib64:/opt/freeware/lib:$LIBPATH
+export PATH=$PATH:.
+
+dbName="metdb"
+schema="MQSMF"
+
+# Connect
+db2 -x connect to $dbName >/dev/null 2>&1
+if [ $? -ne 0 ]
+then
+  echo "Connection to DB2 $dbName failed"
+  exit 1
+else
+ echo "Connected to $dbName"
+fi
+
+# Run the DDL to create the tables
+db2 -tf SMF-MQTABLES.ddl
+
+
+# And import all the data files
+for x in *csv
+do
+  b=`basename $x .csv`
+  f=`echo $b | sed "s/SMF-//g"`
+
+  echo Loading from $b into $f
+  chmod a+r $x
+  db2 load client from $x of del insert into $schema.$f
+done

bin/win/mqsmfcsv.exe

@@ -0,0 +1,40 @@
+# This script is an example of how to populate a MySQL database
+#
+# You will need to modify variables such as where the formatted csv files
+# have been created, and which database/schema to work with.
+
+# Set credentials
+user="root"
+pw="Passw0rd!"
+
+# Where are the output files
+cd /tmp/smf/out
+
+# Which database/schema to work with
+schema="MQSMF"
+
+# Use the "force" option to make the command continue even if
+# there are errors. Will be common to have the DROP TABLE fail for
+# a new database.
+
+# Run the DDL to create the tables
+mysql -u $user --password=$pw --force < SMF-MQTABLES.ddl
+
+# And import all the data files
+for x in *csv
+do
+  b=`basename $x .csv`
+  f=`echo $b | sed "s/SMF-//g"`
+
+  echo Loading from $b into $f
+
+  mysql -u $user --password=$pw --local-infile=1 --force << EOF
+USE $schema;
+
+load data local infile '$x' into table $f
+ fields terminated by ','
+ enclosed by '"'
+ lines terminated by '\n';
+
+EOF
+done