hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[FEAT MERGE] productization of xa trans

Browse Source
This commit is contained in:
obdev
2023-01-28 18:05:52 +08:00
committed by ob-robot
parent 01c6b1fbea
commit f27d2efc83
30 changed files with 500 additions and 180 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/observer/virtual_table/ob_all_virtual_tx_stat.cpp
View File

@ -31,6 +31,7 @@ void ObGVTxStat::reset()
ObVirtualTableScannerIterator::reset();
all_tenants_.reset();
xid_.reset();
init_ = false;
}
@ -43,6 +44,7 @@ void ObGVTxStat::destroy()
ObVirtualTableScannerIterator::reset();
all_tenants_.reset();
xid_.reset();
init_ = false;
}
@ -151,6 +153,7 @@ int ObGVTxStat::inner_get_next_row(ObNewRow *&row)
}
} else {
const int64_t col_count = output_column_ids_.count();
xid_ = tx_stat.xid_;
for (int64_t i = 0; OB_SUCC(ret) && i < col_count; ++i) {
uint64_t col_id = output_column_ids_.at(i);
switch (col_id) {
@ -246,6 +249,37 @@ int ObGVTxStat::inner_get_next_row(ObNewRow *&row)
case IS_EXITING:
cur_row_.cells_[i].set_int(tx_stat.is_exiting_);
break;
case COORD:
cur_row_.cells_[i].set_int(tx_stat.coord_.id());
break;
case LAST_REQUEST_TS:
cur_row_.cells_[i].set_timestamp(tx_stat.last_request_ts_);
break;
case GTRID:
if (!xid_.empty()) {
cur_row_.cells_[i].set_varchar(xid_.get_gtrid_str());
cur_row_.cells_[i].set_collation_type(ObCharset::get_default_collation(ObCharset::get_default_charset()));
} else {
// use default value NULL
cur_row_.cells_[i].reset();
}
break;
case BQUAL:
if (!xid_.empty()) {
cur_row_.cells_[i].set_varchar(xid_.get_bqual_str());
cur_row_.cells_[i].set_collation_type(ObCharset::get_default_collation(ObCharset::get_default_charset()));
} else {
// use default value NULL
cur_row_.cells_[i].reset();
}
break;
case FORMAT_ID:
if (!xid_.empty()) {
cur_row_.cells_[i].set_int(xid_.get_format_id());
} else {
cur_row_.cells_[i].set_int(-1);
}
break;
default:
ret = OB_ERR_UNEXPECTED;
SERVER_LOG(WARN, "invalid coloum_id", K(ret), K(col_id));