INNER CODE UNIT · Rust
get_update_query_and_col_type
lanterndata/lantern · lantern_cli/src/embeddings/mod.rs:267
fn get_update_query_and_col_type(
args: Arc<cli::EmbeddingArgs>,
full_table_name: &str,
temp_table_name: &str,
column_type: &str,
) -> (String, String) {
let column = args.out_column.clone();
let cast_fn_name = get_full_table_name(&args.internal_schema, "ldb_try_cast");
let mut tmp_col_type = column_type.to_owned();
let mut type_check_sql = "".to_owned();
let mut failed_rows_sql = "SELECT 1 WHERE FALSE;".to_owned(); // nop operation
let mut temp_table_subquery = temp_table_name.to_owned(); // nop operation
if let Some(failed_rows_table) = &args.failed_rows_table {
let failed_rows_table = get_full_table_name(&args.internal_schema, failed_rows_table);
failed_rows_sql = format!(
"
INSERT INTO {failed_rows_table} (job_id, row_id, value)