Mirrors/rowy
1
0
Fork 0
mirror of https://github.com/rowyio/rowy.git synced 2026-02-24 04:01:17 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix bigquery spark update and url issue

Browse Source
This commit is contained in:
Bobby
2021-04-30 02:36:50 +10:00
parent bf43103908
commit 7631a19c44
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ft_build/sparksLib/bigqueryIndex.ts
View File

@@ -91,6 +91,7 @@ const transformToSQLValue = (value: any, ftType: string) => {
case "RICH_TEXT":
case "ID":
case "SINGLE_SELECT":
case "URL":
// STRING
return `"${sanitise(value)}"`;
case "JSON":
@@ -174,13 +175,12 @@ const bigqueryIndex = async (payload, sparkContext) => {
console.log(res);
}
async function update(data: Record<string, string>) {
const keys = Object.keys(data);
const dictValues = Array.from(Array(keys.length).keys())
.map((i) => `${keys[i]}=${transformToSQLValue(data[i], fieldTypes[i])}`)
async function update(data) {
const values = Object.keys(data)
.map((key) => `${key}=${transformToSQLValue(data[key], fieldTypes[key])}`)
.join(",");
const query = `UPDATE ${index}
SET ${dictValues}
SET ${values}
WHERE objectID="${objectID}"
;`;
console.log(query);