update table magic
This commit is contained in:
parent
25137f95cf
commit
c46f557a49
|
@ -21,3 +21,4 @@ The database schema is defined in the [migration.sql](migration.sql) file.
|
||||||
For new database installations start with the [init-database.sql](init-database.sql) file.
|
For new database installations start with the [init-database.sql](init-database.sql) file.
|
||||||
Required is a PostgreSQL database (tested version 15).
|
Required is a PostgreSQL database (tested version 15).
|
||||||
|
|
||||||
|
(optional) Create tablespaces following the naming convention (see postgres.rs and [init-database.sql](init-database.sql)).
|
||||||
|
|
|
@ -302,6 +302,7 @@ async fn start_tracking_blocks(
|
||||||
let atl_store = atl_store.clone();
|
let atl_store = atl_store.clone();
|
||||||
|
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
|
info!("spawn task");
|
||||||
// to support address lookup tables delay processing a littlebit
|
// to support address lookup tables delay processing a littlebit
|
||||||
tokio::time::sleep(Duration::from_secs(2)).await;
|
tokio::time::sleep(Duration::from_secs(2)).await;
|
||||||
let block_info = BlockInfo::new(atl_store, &block).await;
|
let block_info = BlockInfo::new(atl_store, &block).await;
|
||||||
|
|
|
@ -194,7 +194,7 @@ impl PostgresSession {
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
// space1,space2,space3
|
// space1, space2, space3
|
||||||
let temp_spaces = spaces.iter()
|
let temp_spaces = spaces.iter()
|
||||||
.map(|space| space.get::<&str, &str>("spcname"))
|
.map(|space| space.get::<&str, &str>("spcname"))
|
||||||
.join(",");
|
.join(",");
|
||||||
|
@ -212,7 +212,7 @@ impl PostgresSession {
|
||||||
.await
|
.await
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.get("temp_tablespaces");
|
.get("temp_tablespaces");
|
||||||
info!("Configured temp_tablespaces={}", temp_tablespaces);
|
info!("Parameter temp_tablespaces={}", temp_tablespaces);
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn drop_temp_table(&self, table: String) -> anyhow::Result<()> {
|
pub async fn drop_temp_table(&self, table: String) -> anyhow::Result<()> {
|
||||||
|
|
Loading…
Reference in New Issue