djkato/CSQL
1
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

working commits!

Browse source
This commit is contained in:
djkato 2023-04-09 14:07:46 +02:00
parent 471b3e7383
commit 62fa057daf
4 changed files with 109 additions and 98 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
docker-compose.yml
View file

@ -15,4 +15,12 @@ services:
- ./demo-db.sql:/docker-entrypoint-initdb.d/init.sql - ./demo-db.sql:/docker-entrypoint-initdb.d/init.sql
volumes: volumes:
db: db:
driver: local driver: local
# To connect to mysql, do:
# sudo docker exec -it csql-Opencart_dummy_DB-1 /bin/bash
# mysql -p
# [password]
# use quotes;
# select * from oc_product;
# clear table: truncate oc_product;

10
src/backend/database_handler.rs
View file

@ -112,21 +112,25 @@ impl Table {
csv_row: Vec<&DataEntry>, csv_row: Vec<&DataEntry>,
) -> QueryResult { ) -> QueryResult {
/* Field_name, data_name */ /* Field_name, data_name */
let fields = csv_row let mut fields = csv_row
.iter() .iter()
.fold(("".to_owned(), "".to_owned()), |row, next_row| { .fold(("".to_owned(), "".to_owned()), |row, next_row| {
( (
row.0 row.0
+ ", "
+ next_row + next_row
.curr_field_description .curr_field_description
.as_ref() .as_ref()
.unwrap() .unwrap()
.field .field
.as_str(), .as_str()
+ ", ",
row.1 + "\'" + next_row.data.as_str() + "\', ", row.1 + "\'" + next_row.data.as_str() + "\', ",
) )
}); });
fields.0.pop();
fields.0.pop();
fields.1.pop();
fields.1.pop();
let query = format!( let query = format!(
"INSERT INTO {}({}) VALUES({})", "INSERT INTO {}({}) VALUES({})",
self.name, fields.0, fields.1 self.name, fields.0, fields.1

170
src/ui/db_transaction_window.rs
View file

@ -34,7 +34,7 @@ impl DBTransactionWindow {
} }
} }
impl DBTransactionWindow { impl DBTransactionWindow {
pub fn show(&mut self, ctx: &Context, ui: &mut Ui) { pub fn show(&mut self, ctx: &Context, ui: &mut Ui, frame: &mut eframe::Frame) {
egui::Window::new("Database Transactions") egui::Window::new("Database Transactions")
.id(egui::Id::new("Database Transactions")) .id(egui::Id::new("Database Transactions"))
.resizable(false) .resizable(false)
@ -43,6 +43,10 @@ impl DBTransactionWindow {
.movable(false) .movable(false)
.scroll2([false, true]) .scroll2([false, true])
.enabled(true) .enabled(true)
.fixed_size(egui::Vec2::new(
frame.info().window_info.size.x / 1.3,
frame.info().window_info.size.y / 1.5,
))
.anchor(egui::Align2::CENTER_CENTER, egui::Vec2::ZERO) .anchor(egui::Align2::CENTER_CENTER, egui::Vec2::ZERO)
.show(ctx, |ui| { .show(ctx, |ui| {
self.log(); self.log();
@ -57,107 +61,97 @@ impl DBTransactionWindow {
} }
if self.is_log_finished_receiver.is_some() { if self.is_log_finished_receiver.is_some() {
if let Ok(finished) = self.is_log_finished_receiver.as_mut().unwrap().try_recv() { if let Ok(finished) = self.is_log_finished_receiver.as_mut().unwrap().try_recv() {
//self.result = Some(finished); self.result = Some(vec![]);
println!("FINISHED THE QUERY!!!"); println!("FINISHED THE QUERY!!!");
} }
} }
let (log_sender, log_receiver) = channel(2); if self.is_log_finished_receiver.is_none() && self.logs_receiver.is_none() {
let (finished_sender, finished_receiver) = oneshot::channel(); let (log_sender, log_receiver) = channel(2);
self.is_log_finished_receiver = Some(finished_receiver); let (finished_sender, finished_receiver) = oneshot::channel();
self.logs_receiver = Some(log_receiver); self.is_log_finished_receiver = Some(finished_receiver);
self.sender self.logs_receiver = Some(log_receiver);
.try_send(Communication::StartInserting( self.sender
self.working_table_index, .try_send(Communication::StartInserting(
log_sender, self.working_table_index,
finished_sender, log_sender,
)) finished_sender,
.unwrap_or_else(|_| println!("Failed to send startInserting")); ))
.unwrap_or_else(|_| println!("Failed to send startInserting"));
}
} }
pub fn ui(&mut self, ctx: &Context, ui: &mut Ui) { pub fn ui(&mut self, ctx: &Context, ui: &mut Ui) {
ui.add_enabled_ui(self.result.is_some(), |ui| { ui.add_enabled_ui(self.result.is_some(), |ui| {
if ui.button("Roll back").clicked() { ui.horizontal(|ui| {
if self.final_result_receiver.is_none() { if ui.button("Roll back").clicked() {
let (sender, receiver) = oneshot::channel(); if self.final_result_receiver.is_none() {
self.final_result_receiver = Some(receiver); let (sender, receiver) = oneshot::channel();
self.sender self.final_result_receiver = Some(receiver);
.try_send(Communication::TryRollBack(sender)) self.sender
.unwrap_or_else(|_| println!("failed sending TryCommit receiver")); .try_send(Communication::TryRollBack(sender))
.unwrap_or_else(|_| println!("failed sending TryCommit receiver"));
}
} }
} if ui.button("Commit").clicked() {
if ui.button("Commit").clicked() { if self.final_result_receiver.is_none() {
if self.final_result_receiver.is_none() { let (sender, receiver) = oneshot::channel();
let (sender, receiver) = oneshot::channel(); self.final_result_receiver = Some(receiver);
self.final_result_receiver = Some(receiver); self.sender
self.sender .try_send(Communication::TryCommit(sender))
.try_send(Communication::TryCommit(sender)) .unwrap_or_else(|_| println!("failed sending TryCommit receiver"));
.unwrap_or_else(|_| println!("failed sending TryCommit receiver")); }
} }
} });
}); });
/* DB Output Stuff */ /* DB Output Stuff */
egui::ScrollArea::vertical() egui::ScrollArea::both()
.auto_shrink([false; 2]) .auto_shrink([false; 2])
.stick_to_bottom(true)
.show(ui, |ui| { .show(ui, |ui| {
egui_extras::StripBuilder::new(ui) let mut table = egui_extras::TableBuilder::new(ui)
.size(egui_extras::Size::remainder().at_least(100.0)) .striped(true)
.size(egui_extras::Size::remainder()) .resizable(true)
.vertical(|mut strip| { .cell_layout(egui::Layout::left_to_right(egui::Align::LEFT))
strip.cell(|ui| { .column(egui_extras::Column::remainder().clip(true))
egui::ScrollArea::horizontal().show(ui, |ui| { .stick_to_bottom(true)
let mut table = egui_extras::TableBuilder::new(ui) .column(egui_extras::Column::remainder().clip(true))
.striped(true) .stick_to_bottom(true);
.resizable(true)
.cell_layout(egui::Layout::left_to_right(egui::Align::LEFT)) table
.column(egui_extras::Column::auto().clip(false)) .header(20.0, |mut header| {
.column(egui_extras::Column::auto().clip(false)) header.col(|ui| {
.min_scrolled_height(0.0); ui.strong("Query");
table });
.header(20.0, |mut header| { header.col(|ui| {
header.col(|ui| { ui.strong("Result");
ui.strong("Query");
});
header.col(|ui| {
ui.strong("Result");
});
})
.body(|mut body| {
body.rows(
15.0,
self.log_history.len(),
|row_index, mut row| {
let log = self.log_history.get(row_index).unwrap();
row.col(|ui| {
ui.label(&log.query);
});
row.col(|ui| {
match &log.result {
Ok(rows) => {
ui.style_mut()
.visuals
.override_text_color =
Some(egui::Color32::RED);
ui.label(format!(
"Success! Rows affected: {}",
rows.rows_affected()
));
}
Err(e) => {
ui.style_mut()
.visuals
.override_text_color =
Some(egui::Color32::RED);
ui.label(format!("Error! {}", e));
}
}
ui.reset_style();
});
},
);
});
ui.scroll_to_cursor(Some(egui::Align::BOTTOM));
});
}); });
}) })
.body(|mut body| {
body.rows(15.0, self.log_history.len(), |row_index, mut row| {
let log = self.log_history.get(row_index).unwrap();
row.col(|ui| {
ui.label(&log.query);
});
row.col(|ui| {
match &log.result {
Ok(rows) => {
ui.style_mut().visuals.override_text_color =
Some(egui::Color32::LIGHT_GREEN);
ui.label(format!(
"Success! Rows affected: {}",
rows.rows_affected()
));
}
Err(e) => {
ui.style_mut().visuals.override_text_color =
Some(egui::Color32::LIGHT_RED);
ui.label(format!("Error! {}", e));
}
}
ui.reset_style();
});
});
});
ui.scroll_to_cursor(Some(egui::Align::BOTTOM));
}); });
} }
} }

17
src/ui/window_manager.rs
View file

@ -71,13 +71,18 @@ impl App for CSQL {
if let Ok(resp) = self.open_db_transaction_window_receiver.try_recv() { if let Ok(resp) = self.open_db_transaction_window_receiver.try_recv() {
self.should_open_db_transaction_window = Some(resp); self.should_open_db_transaction_window = Some(resp);
} }
if self.should_open_db_transaction_window.is_some() { if let Some(db_transaction_window) = self.db_transaction_window.as_mut() {
let db_transaction_window = DBTransactionWindow::default( db_transaction_window.show(ctx, ui, frame)
self.sender.clone(), }
self.should_open_db_transaction_window.unwrap(), if let Some(working_table_index) = self.should_open_db_transaction_window {
); let db_transaction_window =
DBTransactionWindow::default(self.sender.clone(), working_table_index);
self.db_transaction_window = Some(db_transaction_window); self.db_transaction_window = Some(db_transaction_window);
self.db_transaction_window.as_mut().unwrap().show(ctx, ui); self.db_transaction_window
.as_mut()
.unwrap()
.show(ctx, ui, frame);
self.should_open_db_transaction_window = None;
} }
/* Changes self if db connection is verified */ /* Changes self if db connection is verified */