database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-30 19:23:07 +03:00
Code Activity

MCOL-4124 Don't not return error when Insert fails

Browse Source
This commit is contained in:
David Hall
2020-06-29 17:50:11 -05:00
parent 4dddaa0274
commit ff3a7835c5
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
dbcon/mysql/ha_mcs_dml.cpp
View File

@ -545,24 +545,26 @@ int ha_mcs_impl_write_last_batch(TABLE* table, cal_connection_info& ci, bool abo
return rc;
//@Bug 4605
int rc1 = 0;
if ( (rc == 0) && !abort && (!(thd->variables.option_bits & (OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN))))
{
ci.rowsHaveInserted += size;
command = "COMMIT";
rc = ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
else if (useHdfs)
{
ci.rowsHaveInserted += size;
command = "COMMIT";
rc = ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
else if (( rc != 0) || abort )
{
command = "ROLLBACK";
rc =ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
rc = max(rc, rc1);
return rc;
}
@ -631,21 +633,23 @@ int ha_mcs_impl_write_row_(const uchar* buf, TABLE* table, cal_connection_info&
else if (rc != dmlpackageprocessor::DMLPackageProcessor::ACTIVE_TRANSACTION_ERROR)
{
//@Bug 4605
int rc1 = 0;
if ( rc != 0 )
{
command = "ROLLBACK";
rc = ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
else if (( rc == 0 ) && (!(thd->variables.option_bits & (OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN))))
{
command = "COMMIT";
rc = ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
else if (useHdfs)
{
command = "COMMIT";
rc = ProcessCommandStatement ( thd, command, ci, schema );
rc1 = ProcessCommandStatement ( thd, command, ci, schema );
}
rc = max(rc, rc1);
}
}
@ -1698,7 +1702,7 @@ int ha_mcs_impl_write_batch_row_(const uchar* buf, TABLE* table, cal_impl_if::ca
}
else
{
buf = buf + 2 ;
buf = buf + 2;
}
}
else //utf8