@@ -385,7 +385,7 @@ async function db_datavalues_from_fetched_row(columnNames, row, dbname, tablenam
385385 row [ colName ] = row [ colName ] . substr ( 1 )
386386 }
387387 if ( datatypeobj [ colName ] == 'varchar' ) {
388- if ( checkdataishex ( row [ colName ] ) ) {
388+ if ( await checkdataishex ( row [ colName ] ) ) {
389389 row [ colName ] = await converthextoutf ( row [ colName ] )
390390 }
391391 }
@@ -441,7 +441,7 @@ async function hextoutf_insertpayload(columnNames, datatypeobj, payload) {
441441 console . log ( `colName : ${ colName } ` )
442442 if ( payload [ colName ] != 'unsupportedtype' ) {
443443 if ( datatypeobj [ colName ] == 'varchar' && payload [ colName ] . toUpperCase ( ) != 'NULL' ) {
444- if ( checkdataishex ( payload [ colName ] ) ) {
444+ if ( await checkdataishex ( payload [ colName ] ) ) {
445445 payload [ colName ] = await converthextoutf ( payload [ colName ] )
446446 }
447447 }
@@ -458,14 +458,14 @@ async function hextoutf_updatepayload(columnNames, datatypeobj, payload) {
458458 //colobj = payload[colName]
459459 if ( payload [ colName ] [ 'old' ] != 'unsupportedtype' ) {
460460 if ( datatypeobj [ colName ] == 'varchar' && payload [ colName ] [ 'old' ] . toUpperCase ( ) != 'NULL' ) {
461- if ( checkdataishex ( payload [ colName ] [ 'old' ] ) ) {
461+ if ( await checkdataishex ( payload [ colName ] [ 'old' ] ) ) {
462462 payload [ colName ] [ 'old' ] = await converthextoutf ( payload [ colName ] [ 'old' ] )
463463 }
464464 }
465465 }
466466 if ( payload [ colName ] [ 'new' ] != 'unsupportedtype' ) {
467467 if ( datatypeobj [ colName ] == 'varchar' && payload [ colName ] [ 'new' ] . toUpperCase ( ) != 'NULL' ) {
468- if ( checkdataishex ( payload [ colName ] [ 'new' ] ) ) {
468+ if ( await checkdataishex ( payload [ colName ] [ 'new' ] ) ) {
469469 payload [ colName ] [ 'new' ] = await converthextoutf ( payload [ colName ] [ 'new' ] )
470470 }
471471 }
0 commit comments