Projects/muscl
12
4
Fork 0
Code Issues 73 Pull Requests Actions Packages Releases Activity

mysql-admutils: expect Ready from server before continuing
Some checks failed
Build and test / check (push) Failing after 1m16s
Details
Build and test / build (push) Successful in 3m28s
Details
Build and test / check-license (push) Successful in 4m54s
Details
Build and test / test (push) Successful in 3m56s
Details
Build and test / docs (push) Successful in 5m27s
Details

Browse Source
This commit is contained in:
Oystein Kristoffer Tveit
2025-12-03 16:26:08 +09:00
parent da2358353f
commit f1b1c9daca
2 changed files with 28 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/client/mysql_admutils_compatibility/mysql_dbadm.rs
View File

@@ -182,7 +182,20 @@ fn tokio_run_command(command: Command, server_connection: StdUnixStream) -> anyh
.unwrap()
.block_on(async {
let tokio_socket = TokioUnixStream::from_std(server_connection)?;
let message_stream = create_client_to_server_message_stream(tokio_socket);
let mut message_stream = create_client_to_server_message_stream(tokio_socket);
while let Some(Ok(message)) = message_stream.next().await {
match message {
Response::Error(err) => {
anyhow::bail!("{}", err);
}
Response::Ready => break,
message => {
eprintln!("Unexpected message from server: {:?}", message);
}
}
}
match command {
Command::Create(args) => create_databases(args, message_stream).await,
Command::Drop(args) => drop_databases(args, message_stream).await,

15
src/client/mysql_admutils_compatibility/mysql_useradm.rs
View File

@@ -143,7 +143,20 @@ fn tokio_run_command(command: Command, server_connection: StdUnixStream) -> anyh
.unwrap()
.block_on(async {
let tokio_socket = TokioUnixStream::from_std(server_connection)?;
let message_stream = create_client_to_server_message_stream(tokio_socket);
let mut message_stream = create_client_to_server_message_stream(tokio_socket);
while let Some(Ok(message)) = message_stream.next().await {
match message {
Response::Error(err) => {
anyhow::bail!("{}", err);
}
Response::Ready => break,
message => {
eprintln!("Unexpected message from server: {:?}", message);
}
}
}
match command {
Command::Create(args) => create_user(args, message_stream).await,
Command::Delete(args) => drop_users(args, message_stream).await,