Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

you learn something new every day... a schema in pg can't start with a number.

This commit is contained in:
dal 2025-02-05 11:36:31 -07:00
parent f437aea897
commit 2be7383656
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/src/utils/stored_values/mod.rs
View File

@ -41,12 +41,12 @@ pub async fn ensure_stored_values_schema(organization_id: &Uuid) -> Result<()> {
// Create schema and table using raw SQL // Create schema and table using raw SQL
let schema_name = organization_id.to_string().replace("-", "_"); let schema_name = organization_id.to_string().replace("-", "_");
let create_schema_sql = format!( let create_schema_sql = format!(
"CREATE SCHEMA IF NOT EXISTS {}_values", "CREATE SCHEMA IF NOT EXISTS values_{}",
schema_name schema_name
); );
let create_table_sql = format!( let create_table_sql = format!(
"CREATE TABLE IF NOT EXISTS {}_values.values_v1 ( "CREATE TABLE IF NOT EXISTS values_{}.values_v1 (
value text NOT NULL, value text NOT NULL,
dataset_id uuid NOT NULL, dataset_id uuid NOT NULL,
column_name text NOT NULL, column_name text NOT NULL,
@ -60,7 +60,7 @@ pub async fn ensure_stored_values_schema(organization_id: &Uuid) -> Result<()> {
let create_index_sql = format!( let create_index_sql = format!(
"CREATE INDEX IF NOT EXISTS values_v1_embedding_idx "CREATE INDEX IF NOT EXISTS values_v1_embedding_idx
ON {}_values.values_v1 ON values_{}.values_v1
USING ivfflat (embedding vector_cosine_ops)", USING ivfflat (embedding vector_cosine_ops)",
schema_name schema_name
); );