@@ -450,8 +450,8 @@ int spider_db_conn_queue_action(
450
450
(!conn->queued_autocommit_val && conn->autocommit != 0 )
451
451
) &&
452
452
!conn->db_conn ->set_autocommit_in_bulk_sql () &&
453
- (error_num = spider_dbton[ conn->dbton_id ]. db_util ->
454
- append_autocommit (&sql_str, conn->queued_autocommit_val ))
453
+ (error_num = conn->db_conn ->
454
+ set_autocommit (conn-> queued_autocommit_val , ( int *) conn->need_mon ))
455
455
) {
456
456
DBUG_RETURN (error_num);
457
457
}
@@ -462,35 +462,38 @@ int spider_db_conn_queue_action(
462
462
(!conn->queued_sql_log_off_val && conn->sql_log_off != 0 )
463
463
) &&
464
464
!conn->db_conn ->set_sql_log_off_in_bulk_sql () &&
465
- (error_num = spider_dbton[ conn->dbton_id ]. db_util ->
466
- append_sql_log_off (&sql_str, conn->queued_sql_log_off_val ))
465
+ (error_num = conn->db_conn ->
466
+ set_sql_log_off (conn-> queued_sql_log_off_val , ( int *) conn->need_mon ))
467
467
) {
468
468
DBUG_RETURN (error_num);
469
469
}
470
470
if (
471
471
conn->queued_wait_timeout &&
472
472
conn->queued_wait_timeout_val != conn->wait_timeout &&
473
473
!conn->db_conn ->set_wait_timeout_in_bulk_sql () &&
474
- (error_num = spider_dbton[conn->dbton_id ].db_util ->
475
- append_wait_timeout (&sql_str, conn->queued_wait_timeout_val ))
474
+ (error_num = conn->db_conn ->
475
+ set_wait_timeout (conn->queued_wait_timeout_val ,
476
+ (int *) conn->need_mon ))
476
477
) {
477
478
DBUG_RETURN (error_num);
478
479
}
479
480
if (
480
481
conn->queued_sql_mode &&
481
482
conn->queued_sql_mode_val != conn->sql_mode &&
482
483
!conn->db_conn ->set_sql_mode_in_bulk_sql () &&
483
- (error_num = spider_dbton[conn->dbton_id ].db_util ->
484
- append_sql_mode (&sql_str, conn->queued_sql_mode_val ))
484
+ (error_num = conn->db_conn ->
485
+ set_sql_mode (conn->queued_sql_mode_val ,
486
+ (int *) conn->need_mon ))
485
487
) {
486
488
DBUG_RETURN (error_num);
487
489
}
488
490
if (
489
491
conn->queued_time_zone &&
490
492
conn->queued_time_zone_val != conn->time_zone &&
491
493
!conn->db_conn ->set_time_zone_in_bulk_sql () &&
492
- (error_num = spider_dbton[conn->dbton_id ].db_util ->
493
- append_time_zone (&sql_str, conn->queued_time_zone_val ))
494
+ (error_num = conn->db_conn ->
495
+ set_time_zone (conn->queued_time_zone_val ,
496
+ (int *) conn->need_mon ))
494
497
) {
495
498
DBUG_RETURN (error_num);
496
499
}
0 commit comments