@@ -232,6 +232,7 @@ void TCommandDescribe::Config(TConfig& config) {
232
232
233
233
void TCommandDescribe::Parse (TConfig& config) {
234
234
TClientCommand::Parse (config);
235
+ Database = config.Database ;
235
236
ParseFormats ();
236
237
ParsePath (config, 0 );
237
238
}
@@ -466,6 +467,13 @@ static TString ProgressOr(const std::optional<float>& value, const U& orValue) {
466
467
}
467
468
}
468
469
470
+ static TStringBuf SkipDatabasePrefix (TStringBuf value, TStringBuf prefix) {
471
+ if (value.SkipPrefix (prefix)) {
472
+ value.Skip (1 ); // skip '/'
473
+ }
474
+ return value;
475
+ }
476
+
469
477
int TCommandDescribe::PrintReplicationResponsePretty (const NYdb::NReplication::TDescribeReplicationResult& result) const {
470
478
const auto & desc = result.GetReplicationDescription ();
471
479
@@ -492,6 +500,9 @@ int TCommandDescribe::PrintReplicationResponsePretty(const NYdb::NReplication::T
492
500
}
493
501
494
502
const auto & connParams = desc.GetConnectionParams ();
503
+ const auto & srcDatabase = connParams.GetDatabase ();
504
+ const auto & dstDatabase = Database;
505
+
495
506
Cout << Endl << " Endpoint: " << connParams.GetDiscoveryEndpoint ();
496
507
Cout << Endl << " Database: " << connParams.GetDatabase ();
497
508
@@ -516,8 +527,8 @@ int TCommandDescribe::PrintReplicationResponsePretty(const NYdb::NReplication::T
516
527
for (const auto & item : items) {
517
528
auto & row = table.AddRow ()
518
529
.Column (0 , item.Id )
519
- .Column (1 , item.SrcPath )
520
- .Column (2 , item.DstPath )
530
+ .Column (1 , SkipDatabasePrefix ( TStringBuf ( item.SrcPath ), TStringBuf (srcDatabase)) )
531
+ .Column (2 , SkipDatabasePrefix ( TStringBuf ( item.DstPath ), TStringBuf (dstDatabase)) )
521
532
.Column (3 , ValueOr (item.SrcChangefeedName , " n/a" ));
522
533
if (ShowStats) {
523
534
row
0 commit comments