@@ -158,7 +158,7 @@ mi_string *doInsertCN()
158158 //fixname(pdbname);
159159 sprintf (& buffer [posi ], "\"SCHEMANAME\": \"%s\", " , pdbname );
160160 posi = strlen (buffer );
161- printf ("\"TABLENAME\": \"%s\", " , tabname );
161+ printf ("\"DBNAME- TABLENAME-operation-TIME \": \"%s-%s-INSERT-%s\" \n" , pdbname , tabname , cdatetime );
162162 sprintf (& buffer [posi ], "\"TABLENAME\": \"%s\", " , tabname );
163163 posi = strlen (buffer );
164164 sprintf (& buffer [posi ], "\"OPERATION\": \"INSERT\", " );
@@ -182,7 +182,9 @@ DPRINTF("logger", 90, ("insert: colname: (0x%x) [%s]", pcolname, pcolname));
182182 sprintf (& buffer [posi ], ", " );
183183 posi = strlen (buffer );
184184 }
185- sprintf (& buffer [posi ], "\"%s\" : \"%s\"" , pcolname , escapecharjson (pcast ));
185+ char * bufdatval = escapecharjson (pcast );
186+ sprintf (& buffer [posi ], "\"%s\" : \"%s\"" , pcolname , bufdatval );
187+ free (bufdatval );
186188 if (strcmp ("unsupportedtype" , pcast ) == 0 ) {
187189 strcpy (uniquedatatype , "true" );
188190 }
@@ -200,6 +202,7 @@ DPRINTF("logger", 90, ("insert: colname: (0x%x) [%s]", pcolname, pcolname));
200202 } else {
201203 sprintf (& buffer [posi ], "}, \n \"uniquedatatype\" : \"false\" \n }" );
202204 }
205+ printf ("\"DBNAME-TABLENAME-operation-TIME\": \"%s-%s-INSERT-%s-Completed\" \n" ,pdbname ,tabname ,cdatetime );
203206 free (cdatetime );
204207 return (buffer );
205208}
@@ -310,6 +313,7 @@ mi_string *doDeleteCN()
310313 sprintf (& buffer [posi ], "\"SCHEMANAME\": \"%s\", " , pdbname );
311314 posi = strlen (buffer );
312315 sprintf (& buffer [posi ], "\"TABLENAME\": \"%s\", " , ptabname );
316+ printf ("\"DBNAME-TABLENAME-operation-TIME\": \"%s-%s-DELETE-%s\" \n" , pdbname ,ptabname ,cdatetime );
313317 posi = strlen (buffer );
314318 sprintf (& buffer [posi ], "\"OPERATION\": \"DELETE\", " );
315319 posi = strlen (buffer );
@@ -336,7 +340,9 @@ DPRINTF("logger", 90, ("delete: colname: (0x%x) [%s]", pcolname, pcolname));
336340
337341 //pcast = escapecharjson(pcast);
338342 //printf("%s",pcast);
339- sprintf (& buffer [posi ], "\"%s\" : \"%s\"" , pcolname , escapecharjson (pcast ));
343+ char * bufdatdelval = escapecharjson (pcast );
344+ sprintf (& buffer [posi ], "\"%s\" : \"%s\"" , pcolname , bufdatdelval );
345+ free (bufdatdelval )
340346 if (strcmp ("unsupportedtype ", pcast ) == 0 ) {
341347 strcpy (uniquedatatype , "true" );
342348 }
@@ -355,6 +361,7 @@ DPRINTF("logger", 90, ("delete: colname: (0x%x) [%s]", pcolname, pcolname));
355361 } else {
356362 sprintf (& buffer [posi ], "}, \n \"uniquedatatype\" : \"false\" \n }" );
357363 }
364+ printf ("\"DBNAME-TABLENAME-operation-TIME\": \"%s-%s-DELETE-%s-Completed\" \n " , pdbname ,ptabname ,cdatetime );
358365 free (cdatetime );
359366 return (buffer );
360367}
@@ -406,7 +413,8 @@ mi_string *doUpdateCN()
406413 //fixname(pdbname);
407414 sprintf (& buffer [posi ], "\"SCHEMANAME\": \"%s\", " , pdbname );
408415 posi = strlen (buffer );
409- sprintf (& buffer [posi ], "\"TABLENAME\": \"%s\", " , ptabname );
416+ sprintf (& buffer [posi ], "\"TABLENAME\": \"%s\", " , ptabname );
417+ printf ("\"DBNAME-TABLENAME-operation-TIME\": \"%s-%s-UPDATE-%s\" \n" , pdbname ,ptabname ,cdatetime );
410418 posi = strlen (buffer );
411419 sprintf (& buffer [posi ], "\"OPERATION\": \"UPDATE\", " );
412420 posi = strlen (buffer );
@@ -448,7 +456,11 @@ mi_string *doUpdateCN()
448456 sprintf (& buffer [pbufLen ], ", " );
449457 pbufLen = strlen (buffer );
450458 }
451- sprintf (& buffer [pbufLen ], "\"%s\" : { \"old\" : \"%s\", \"new\" : \"%s\" }" , poldcolname , escapecharjson (pcast ), escapecharjson (pcast2 ));
459+ char * bufdatoldval = escapecharjson (pcast );
460+ char * bufdatnewval = escapecharjson (pcast2 );
461+ sprintf (& buffer [pbufLen ], "\"%s\" : { \"old\" : \"%s\", \"new\" : \"%s\" }" , poldcolname , bufdatoldval , bufdatnewval );
462+ free (bufdatoldval );
463+ free (bufdatnewval );
452464 if (strcmp ("unsupportedtype" , pcast2 ) == 0 ) {
453465 strcpy (uniquedatatype , "true" );
454466 }
@@ -464,6 +476,7 @@ mi_string *doUpdateCN()
464476 sprintf (& buffer [pbufLen ], "}, \n \"uniquedatatype\" : \"false\" \n }" );
465477 }
466478 DPRINTF ("logger" , 90 , ("Exiting doUpdateCN()" ));
479+ printf ("\"DBNAME-TABLENAME-operation-TIME\": \"%s-%s-UPDATE-%s-Completed\" \n " , pdbname ,ptabname ,cdatetime );
467480 free (cdatetime );
468481 return (buffer );
469482}
@@ -579,7 +592,7 @@ char * escapecharjson( char *jsonvalue_org)
579592 escjsonvalue = (char * )calloc (10000 , sizeof (char ));
580593 for (jsonvalue_copy = jsonvalue_org ; * jsonvalue_copy != '\0' ; jsonvalue_copy ++ ) {
581594
582- printf ("%c:%d\n" , * jsonvalue_copy ,* jsonvalue_copy );
595+ // printf("%c:%d\n", *jsonvalue_copy,*jsonvalue_copy);
583596 if (* jsonvalue_copy == '"' ) {
584597 posi = strlen (escjsonvalue );
585598 sprintf (& escjsonvalue [posi ], "%s" ,"\\\"" ) ;
@@ -616,6 +629,6 @@ char * escapecharjson( char *jsonvalue_org)
616629 }
617630 //p=NULL;
618631 jsonvalue_copy = NULL ;
619- printf ("%s" , escjsonvalue );
632+ // printf("%s", escjsonvalue);
620633 return (escjsonvalue );
621634 }
0 commit comments