rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-19 14:10:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

WIP: fast-import: change postgres database to neondb

Browse Source
This commit is contained in:
Gleb Novikov
2024-12-19 18:33:23 +00:00
parent 04517c6ff3
commit 4f79f8c0d1
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
compute_tools/src/bin/fast_import.rs
View File

@@ -189,12 +189,26 @@ pub(crate) async fn main() -> anyhow::Result<()> {
format!("host=localhost port=5432 user={superuser} dbname=postgres");
loop {
let res = tokio_postgres::connect(&restore_pg_connstring, tokio_postgres::NoTls).await;
if res.is_ok() {
if let Ok((client, connection)) = res {
info!("postgres is ready, could connect to it");
tokio::spawn(async move {
if let Err(e) = connection.await {
eprintln!("connection error: {}", e);
}
});
client
.execute("CREATE DATABASE neondb", &[])
.await
.context("create database neondb")?;
break;
}
}
let restore_pg_connstring = restore_pg_connstring.replace("dbname=postgres", "dbname=neondb");
//
// Decrypt connection string
//