Skip to content

Commit 1e82759

Browse files
committed
chore: update schema load to check for new type
1 parent 3874bbf commit 1e82759

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

  • packages/cipherstash-proxy/src/encrypt/schema

packages/cipherstash-proxy/src/encrypt/schema/manager.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -132,17 +132,16 @@ pub async fn load_schema(config: &DatabaseConfig) -> Result<Schema, Error> {
132132
let table_name: String = table.get("table_name");
133133
let primary_keys: Vec<Option<String>> = table.get("primary_keys");
134134
let columns: Vec<String> = table.get("columns");
135-
let _types: Vec<Option<String>> = table.get("column_types");
136-
let domains: Vec<Option<String>> = table.get("column_domains");
135+
let column_type_names: Vec<Option<String>> = table.get("column_type_names");
137136

138137
let mut table = Table::new(Ident::new(&table_name));
139138

140-
columns.iter().zip(domains).for_each(|(col, domain)| {
139+
columns.iter().zip(column_type_names).for_each(|(col, column_type_name)| {
141140
let is_primary_key = primary_keys.contains(&Some(col.to_string()));
142141

143142
let ident = Ident::with_quote('"', col);
144143

145-
let column = match domain.as_deref() {
144+
let column = match column_type_name.as_deref() {
146145
Some("eql_v1_encrypted") => {
147146
debug!(target: SCHEMA, msg = "eql_v1_encrypted column", table = table_name, column = col);
148147
Column::eql(ident)

0 commit comments

Comments
 (0)