github
/
nocodb
mirror of https://github.com/nocodb/nocodb
1
0
Fork 0
Code Issues Releases Wiki Activity
Browse Source

refactor: comments cleanup 

Signed-off-by: Raju Udava <86527202+dstala@users.noreply.github.com>
pull/5280/head
Raju Udava 2 years ago
parent
636e9babb9
commit
80b122afa9
2 changed files with 3 additions and 265 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 236
      packages/nocodb/src/lib/services/sync/helpers/job.ts
  2. 32
      packages/nocodb/src/lib/services/sync/helpers/readAndProcessData.ts

236
packages/nocodb/src/lib/services/sync/helpers/job.ts
Unescape View File

@ -1,6 +1,5 @@
import { promisify } from 'util';
import { UITypes } from 'nocodb-sdk';
// import * as sMap from './syncMap';
import Airtable from 'airtable';
import jsonfile from 'jsonfile';
@ -307,16 +306,6 @@ export default async (
};
}
// aTbl: retrieve table name from table ID
//
// @ts-ignore
function aTbl_getTableName(tblId) {
const sheetObj = g_aTblSchema.find((tbl) => tbl.id === tblId);
return {
tn: sheetObj.name,
};
}
const ncSchema = {
tables: [],
tablesById: {},
@ -368,13 +357,6 @@ export default async (
// retrieve nc column schema from using aTbl field ID as reference
//
async function nc_getColumnSchema(aTblFieldId) {
// let ncTblList = await api.dbTable.list(ncCreatedProjectSchema.id);
// let aTblField = aTbl_getColumnName(aTblFieldId);
// let ncTblId = ncTblList.list.filter(x => x.title === aTblField.tn)[0].id;
// let ncTbl = await api.dbTable.read(ncTblId);
// let ncCol = ncTbl.columns.find(x => x.title === aTblField.cn);
// return ncCol;
const ncTblId = await sMap.getNcParentFromAtId(aTblFieldId);
const ncColId = await sMap.getNcIdFromAtId(aTblFieldId);
@ -388,11 +370,6 @@ export default async (
// optimize: create a look-up table & re-use information
//
async function nc_getTableSchema(tableName) {
// let ncTblList = await api.dbTable.list(ncCreatedProjectSchema.id);
// let ncTblId = ncTblList.list.filter(x => x.title === tableName)[0].id;
// let ncTbl = await api.dbTable.read(ncTblId);
// return ncTbl;
return ncSchema.tables.find((x) => x.title === tableName);
}
@ -404,7 +381,6 @@ export default async (
projectId?: string;
}) {
// delete 'sample' project if already exists
// const x = await api.project.list();
const x = { list: [] };
x['list'] = await projectService.projectList({
user: { id: syncDB.user.id, roles: syncDB.user.roles },
@ -412,7 +388,6 @@ export default async (
const sampleProj = x.list.find((a) => a.title === projectName);
if (sampleProj) {
// await api.project.delete(sampleProj.id);
await projectService.projectSoftDelete({
projectId: sampleProj.id,
});
@ -461,11 +436,6 @@ export default async (
case 'date':
if (col.typeOptions?.isDateTime) ncType = UITypes.DateTime;
break;
// case 'barcode':
// case 'button':
// ncType = UITypes.SingleLineText;
// break;
}
return ncType;
@ -492,7 +462,9 @@ export default async (
(value as any).name = 'nc_empty';
}
// enumerate duplicates (we don't allow them)
// TODO fix record mapping (this causes every record to map first option, we can't handle them using data api as they don't provide option id within data we might instead get the correct mapping from schema file )
// TODO fix record mapping (this causes every record to map first option,
// we can't handle them using data api as they don't provide option id
// within data we might instead get the correct mapping from schema file )
let dupNo = 1;
const defaultName = (value as any).name;
while (
@ -602,13 +574,6 @@ export default async (
continue;
}
// populate cdf (column default value) if configured
// if (col?.default) {
// if (typeof col.default === 'string')
// ncCol.cdf = `'${col.default.replace?.(/'/g, "\\'")}'`;
// else ncCol.cdf = col.default;
// }
// change from default 'tinytext' as airtable allows more than 255 characters
// for single line text column type
if (col.type === 'text') ncCol.dt = 'text';
@ -665,11 +630,6 @@ export default async (
logDetailed(`NC API: base.tableCreate ${tables[idx].title}`);
let _perfStart = recordPerfStart();
// const table: any = await api.base.tableCreate(
// ncCreatedProjectSchema.id,
// syncDB.baseId,
// tables[idx]
// );
const table = await tableService.tableCreate({
baseId: syncDB.baseId,
projectId: ncCreatedProjectSchema.id,
@ -699,7 +659,6 @@ export default async (
// update default view name- to match it to airtable view name
logDetailed(`NC API: dbView.list ${table.id}`);
_perfStart = recordPerfStart();
// const view = await api.dbView.list(table.id);
const view = { list: [] };
view['list'] = await viewService.viewList({
tableId: table.id,
@ -710,9 +669,6 @@ export default async (
const aTbl_grid = aTblSchema[idx].views.find((x) => x.type === 'grid');
logDetailed(`NC API: dbView.update ${view.list[0].id} ${aTbl_grid.name}`);
_perfStart = recordPerfStart();
// await api.dbView.update(view.list[0].id, {
// title: aTbl_grid.name,
// });
await viewService.viewUpdate({
viewId: view.list[0].id,
view: { title: aTbl_grid.name },
@ -763,7 +719,6 @@ export default async (
// check if link already established?
if (!nc_isLinkExists(aTblLinkColumns[i].id)) {
// parent table ID
// let srcTableId = (await nc_getTableSchema(aTblSchema[idx].name)).id;
const srcTableId = await sMap.getNcIdFromAtId(aTblSchema[idx].id);
// find child table name from symmetric column ID specified
@ -780,7 +735,6 @@ export default async (
// check if already a column exists with this name?
let _perfStart = recordPerfStart();
// const srcTbl: any = await api.dbTable.read(srcTableId);
const srcTbl: any = await tableService.getTableWithAccessibleViews({
tableId: srcTableId,
user: syncDB.user,
@ -801,17 +755,6 @@ export default async (
`NC API: dbTableColumn.create LinkToAnotherRecord ${ncName.title}`
);
_perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.create(srcTableId, {
// uidt: UITypes.LinkToAnotherRecord,
// title: ncName.title,
// column_name: ncName.column_name,
// parentId: srcTableId,
// childId: childTableId,
// type: 'mm',
// // aTblLinkColumns[i].typeOptions.relationship === 'many'
// // ? 'mm'
// // : 'hm'
// });
const ncTbl: any = await columnService.columnAdd({
tableId: srcTableId,
column: {
@ -821,9 +764,6 @@ export default async (
parentId: srcTableId,
childId: childTableId,
type: 'mm',
// aTblLinkColumns[i].typeOptions.relationship === 'many'
// ? 'mm'
// : 'hm'
},
req: {
user: syncDB.user.email,
@ -876,9 +816,6 @@ export default async (
);
let _perfStart = recordPerfStart();
// const childTblSchema: any = await api.dbTable.read(
// ncLinkMappingTable[x].nc.childId
// );
const childTblSchema: any =
await tableService.getTableWithAccessibleViews({
tableId: ncLinkMappingTable[x].nc.childId,
@ -887,9 +824,6 @@ export default async (
recordPerfStats(_perfStart, 'dbTable.read');
_perfStart = recordPerfStart();
// const parentTblSchema: any = await api.dbTable.read(
// ncLinkMappingTable[x].nc.parentId
// );
const parentTblSchema: any =
await tableService.getTableWithAccessibleViews({
tableId: ncLinkMappingTable[x].nc.parentId,
@ -897,10 +831,6 @@ export default async (
});
recordPerfStats(_perfStart, 'dbTable.read');
// fix me
// let childTblSchema = ncSchema.tablesById[ncLinkMappingTable[x].nc.childId]
// let parentTblSchema = ncSchema.tablesById[ncLinkMappingTable[x].nc.parentId]
let parentLinkColumn = parentTblSchema.columns.find(
(col) => col.title === ncLinkMappingTable[x].nc.title
);
@ -973,14 +903,6 @@ export default async (
`NC API: dbTableColumn.update rename symmetric column ${ncName.title}`
);
_perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.update(
// childLinkColumn.id,
// {
// ...childLinkColumn,
// title: ncName.title,
// column_name: ncName.column_name,
// }
// );
const ncTbl: any = await columnService.columnUpdate({
columnId: childLinkColumn.id,
column: {
@ -1002,8 +924,6 @@ export default async (
aTblLinkColumns[i].name + suffix,
ncTbl.id
);
// console.log(res.columns.find(x => x.title === aTblLinkColumns[i].name))
}
}
}
@ -1018,7 +938,6 @@ export default async (
);
// parent table ID
// let srcTableId = (await nc_getTableSchema(aTblSchema[idx].name)).id;
const srcTableId = await sMap.getNcIdFromAtId(aTblSchema[idx].id);
const srcTableSchema = ncSchema.tablesById[srcTableId];
@ -1070,13 +989,6 @@ export default async (
logDetailed(`NC API: dbTableColumn.create LOOKUP ${ncName.title}`);
const _perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.create(srcTableId, {
// uidt: UITypes.Lookup,
// title: ncName.title,
// column_name: ncName.column_name,
// fk_relation_column_id: ncRelationColumnId,
// fk_lookup_column_id: ncLookupColumnId,
// });
const ncTbl: any = await columnService.columnAdd({
tableId: srcTableId,
column: {
@ -1164,13 +1076,6 @@ export default async (
logDetailed(`NC API: dbTableColumn.create LOOKUP ${ncName.title}`);
const _perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.create(srcTableId, {
// uidt: UITypes.Lookup,
// title: ncName.title,
// column_name: ncName.column_name,
// fk_relation_column_id: ncRelationColumnId,
// fk_lookup_column_id: ncLookupColumnId,
// });
const ncTbl: any = await columnService.columnAdd({
tableId: srcTableId,
column: {
@ -1236,7 +1141,6 @@ export default async (
);
// parent table ID
// let srcTableId = (await nc_getTableSchema(aTblSchema[idx].name)).id;
const srcTableId = await sMap.getNcIdFromAtId(aTblSchema[idx].id);
const srcTableSchema = ncSchema.tablesById[srcTableId];
@ -1254,7 +1158,6 @@ export default async (
const ncRollupFn = getRollupNcFunction(
aTblColumns[i].typeOptions.formulaTextParsed
);
// const ncRollupFn = '';
if (ncRollupFn === '' || ncRollupFn === undefined) {
updateMigrationSkipLog(
@ -1321,14 +1224,6 @@ export default async (
logDetailed(`NC API: dbTableColumn.create ROLLUP ${ncName.title}`);
const _perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.create(srcTableId, {
// uidt: UITypes.Rollup,
// title: ncName.title,
// column_name: ncName.column_name,
// fk_relation_column_id: ncRelationColumnId,
// fk_rollup_column_id: ncRollupColumnId,
// rollup_function: ncRollupFn,
// });
const ncTbl: any = await columnService.columnAdd({
tableId: srcTableId,
column: {
@ -1394,13 +1289,6 @@ export default async (
logDetailed(`NC API: dbTableColumn.create LOOKUP ${ncName.title}`);
const _perfStart = recordPerfStart();
// const ncTbl: any = await api.dbTableColumn.create(srcTableId, {
// uidt: UITypes.Lookup,
// title: ncName.title,
// column_name: ncName.column_name,
// fk_relation_column_id: ncRelationColumnId,
// fk_lookup_column_id: ncLookupColumnId,
// });
const ncTbl: any = await columnService.columnAdd({
tableId: srcTableId,
column: {
@ -1449,7 +1337,6 @@ export default async (
if (ncColId) {
logDetailed(`NC API: dbTableColumn.primaryColumnSet`);
const _perfStart = recordPerfStart();
// await api.dbTableColumn.primaryColumnSet(ncColId);
await columnService.columnSetAsPrimary({ columnId: ncColId });
recordPerfStats(_perfStart, 'dbTableColumn.primaryColumnSet');
@ -1467,18 +1354,15 @@ export default async (
const _perfStart = recordPerfStart();
if (viewType === 'form') {
// viewDetails = (await api.dbView.formRead(viewId)).columns;
viewDetails = (await formViewService.formViewGet({ formViewId: viewId }))
.columns;
recordPerfStats(_perfStart, 'dbView.formRead');
} else if (viewType === 'gallery') {
// viewDetails = (await api.dbView.galleryRead(viewId)).columns;
viewDetails = (
await galleryViewService.galleryViewGet({ galleryViewId: viewId })
).columns;
recordPerfStats(_perfStart, 'dbView.galleryRead');
} else {
// viewDetails = await api.dbView.gridColumnsList(viewId);
viewDetails = await viewColumnService.columnList({ viewId: viewId });
recordPerfStats(_perfStart, 'dbView.gridColumnsList');
}
@ -1607,17 +1491,6 @@ export default async (
?.map((a) => a.filename?.split('?')?.[0])
.join(', ')}`
);
// tempArr = await api.storage.uploadByUrl(
// {
// path: `noco/${sDB.projectName}/${table.title}/${key}`,
// },
// value?.map((attachment) => ({
// fileName: attachment.filename?.split('?')?.[0],
// url: attachment.url,
// size: attachment.size,
// mimetype: attachment.type,
// }))
// );
tempArr = await attachmentService.uploadViaURL({
path: `noco/${sDB.projectName}/${table.title}/${key}`,
urls: value?.map((attachment) => ({
@ -1665,8 +1538,6 @@ export default async (
})
.eachPage(
async function page(records, fetchNextPage) {
// console.log(JSON.stringify(records, null, 2));
// This function (`page`) will get called for each page of records.
// records.forEach(record => callback(table, record));
logBasic(
@ -1706,9 +1577,6 @@ export default async (
// create empty project (XC-DB)
logDetailed(`Create Project: ${projName}`);
const _perfStart = recordPerfStart();
// ncCreatedProjectSchema = await api.project.create({
// title: projName,
// });
ncCreatedProjectSchema = await projectService.projectCreate({
project: { title: projName },
@ -1722,7 +1590,6 @@ export default async (
// create empty project (XC-DB)
logDetailed(`Getting project meta: ${projId}`);
const _perfStart = recordPerfStart();
// ncCreatedProjectSchema = await api.project.read(projId);
ncCreatedProjectSchema = await projectService.getProjectWithInfo({
projectId: projId,
});
@ -1757,7 +1624,6 @@ export default async (
logDetailed(`NC API dbView.galleryCreate :: ${viewName}`);
const _perfStart = recordPerfStart();
// await api.dbView.galleryCreate(tblId, { title: viewName });
await galleryViewService.galleryViewCreate({
tableId: tblId,
gallery: {
@ -1767,9 +1633,6 @@ export default async (
recordPerfStats(_perfStart, 'dbView.galleryCreate');
await updateNcTblSchemaById(tblId);
// syncLog(`[${idx+1}/${aTblSchema.length}][Gallery View][${i+1}/${galleryViews.length}] Create ${viewName}`)
// await nc_configureFields(g.id, vData, aTblSchema[idx].name, viewName, 'gallery');
}
}
}
@ -1891,9 +1754,6 @@ export default async (
if (i > 0) {
logDetailed(`NC API dbView.gridCreate :: ${viewName}`);
const _perfStart = recordPerfStart();
// const viewCreated = await api.dbView.gridCreate(tblId, {
// title: viewName,
// });
const viewCreated = await gridViewService.gridViewCreate({
tableId: tblId,
grid: {
@ -1909,11 +1769,9 @@ export default async (
viewName,
tblId
);
// syncLog(`[${idx+1}/${aTblSchema.length}][Grid View][${i+1}/${gridViews.length}] Create ${viewName}`)
ncViewId = viewCreated.id;
}
// syncLog(`[${idx+1}/${aTblSchema.length}][Grid View][${i+1}/${gridViews.length}] Hide columns ${viewName}`)
logDetailed(` Configure show/hide columns`);
await nc_configureFields(
ncViewId,
@ -1925,7 +1783,6 @@ export default async (
// configure filters
if (vData?.filters) {
// syncLog(`[${idx+1}/${aTblSchema.length}][Grid View][${i+1}/${gridViews.length}] Configure filters ${viewName}`)
logDetailed(` Configure filter set`);
// skip filters if nested
@ -1936,7 +1793,6 @@ export default async (
// configure sort
if (vData?.lastSortsApplied?.sortSet.length) {
// syncLog(`[${idx+1}/${aTblSchema.length}][Grid View][${i+1}/${gridViews.length}] Configure sort ${viewName}`)
logDetailed(` Configure sort set`);
await nc_configureSort(ncViewId, vData.lastSortsApplied);
}
@ -1966,11 +1822,6 @@ export default async (
);
const _perfStart = recordPerfStart();
insertJobs.push(
// api.auth
// .projectUserAdd(ncCreatedProjectSchema.id, {
// email: value.email,
// roles: userRoles[value.permissionLevel],
// })
projectUserService
.userInvite({
projectId: ncCreatedProjectSchema.id,
@ -2005,7 +1856,6 @@ export default async (
async function updateNcTblSchemaById(tblId) {
const _perfStart = recordPerfStart();
// const ncTbl = await api.dbTable.read(tblId);
const ncTbl: any = await tableService.getTableWithAccessibleViews({
tableId: tblId,
user: syncDB.user,
@ -2266,9 +2116,6 @@ export default async (
// insert filters
for (let i = 0; i < ncFilters.length; i++) {
const _perfStart = recordPerfStart();
// await api.dbTableFilter.create(viewId, {
// ...ncFilters[i],
// });
await filterService.filterCreate({
viewId: viewId,
filter: ncFilters[i],
@ -2286,10 +2133,6 @@ export default async (
if (columnId) {
const _perfStart = recordPerfStart();
// await api.dbTableSort.create(viewId, {
// fk_column_id: columnId,
// direction: s.sortSet[i].ascending ? 'asc' : 'desc',
// });
await sortService.sortCreate({
viewId: viewId,
sort: {
@ -2317,12 +2160,10 @@ export default async (
const _perfStart = recordPerfStart();
if (viewType === 'form') {
// viewDetails = (await api.dbView.formRead(viewId)).columns;
viewDetails = (await formViewService.formViewGet({ formViewId: viewId }))
.columns;
recordPerfStats(_perfStart, 'dbView.formRead');
} else if (viewType === 'gallery') {
// viewDetails = (await api.dbView.galleryRead(viewId)).columns;
viewDetails = (
await galleryViewService.galleryViewGet({
galleryViewId: viewId,
@ -2330,7 +2171,6 @@ export default async (
).columns;
recordPerfStats(_perfStart, 'dbView.galleryRead');
} else {
// viewDetails = await api.dbView.gridColumnsList(viewId);
viewDetails = await viewColumnService.columnList({ viewId: viewId });
recordPerfStats(_perfStart, 'dbView.gridColumnsList');
}
@ -2343,19 +2183,10 @@ export default async (
const ncViewColumnId = viewDetails.find(
(x) => x.fk_column_id === ncColumnId
)?.id;
// const ncViewColumnId = await nc_getViewColumnId(
// viewId,
// viewType,
// ncColumnId
// );
if (ncViewColumnId === undefined) continue;
// first two positions held by record id & record hash
const _perfStart = recordPerfStart();
// await api.dbViewColumn.update(viewId, ncViewColumnId, {
// show: false,
// order: j + 1 + c.length,
// });
await viewColumnService.columnUpdate({
viewId: viewId,
columnId: ncViewColumnId,
@ -2387,7 +2218,6 @@ export default async (
if (x?.required) formData[`required`] = x.required;
if (x?.description) formData[`description`] = x.description;
const _perfStart = recordPerfStart();
// await api.dbView.formColumnUpdate(ncViewColumnId, formData);
await formViewColumnService.columnUpdate({
formViewColumnId: ncViewColumnId,
formViewColumn: formData,
@ -2396,7 +2226,6 @@ export default async (
}
}
const _perfStart = recordPerfStart();
// await api.dbViewColumn.update(viewId, ncViewColumnId, configData);
await viewColumnService.columnUpdate({
viewId: viewId,
columnId: ncViewColumnId,
@ -2489,10 +2318,6 @@ export default async (
try {
// await nc_DumpTableSchema();
const _perfStart = recordPerfStart();
// const ncTblList = await api.base.tableList(
// ncCreatedProjectSchema.id,
// syncDB.baseId
// );
const ncTblList = { list: [] };
ncTblList['list'] = await tableService.getAccessibleTables({
projectId: ncCreatedProjectSchema.id,
@ -2514,7 +2339,6 @@ export default async (
continue;
const _perfStart = recordPerfStart();
// const ncTbl = await api.dbTable.read(ncTblList.list[i].id);
const ncTbl: any = await tableService.getTableWithAccessibleViews({
tableId: ncTblList.list[i].id,
user: syncDB.user,
@ -2522,7 +2346,6 @@ export default async (
recordPerfStats(_perfStart, 'dbTable.read');
recordCnt = 0;
// await nocoReadData(syncDB, ncTbl);
recordsMap[ncTbl.id] = await importData({
projectName: syncDB.projectName,
@ -2567,59 +2390,6 @@ export default async (
syncDB,
});
}
if (storeLinks) {
// const insertJobs: Promise<any>[] = [];
// for (const [pTitle, v] of Object.entries(ncLinkDataStore)) {
// logBasic(`:: ${pTitle}`);
// for (const [, record] of Object.entries(v)) {
// const tbl = ncTblList.list.find(a => a.title === pTitle);
// await nocoLinkProcessing(syncDB.projectName, tbl, record, 0);
// // insertJobs.push(
// // nocoLinkProcessing(syncDB.projectName, tbl, record, 0)
// // );
// }
// }
// await Promise.all(insertJobs);
// await nocoLinkProcessing(syncDB.projectName, 0, 0, 0);
} else {
// // create link groups (table: link fields)
// // const tblLinkGroup = {};
// // for (let idx = 0; idx < ncLinkMappingTable.length; idx++) {
// // const x = ncLinkMappingTable[idx];
// // if (tblLinkGroup[x.aTbl.tblId] === undefined)
// // tblLinkGroup[x.aTbl.tblId] = [x.aTbl.name];
// // else tblLinkGroup[x.aTbl.tblId].push(x.aTbl.name);
// // }
// //
// // const ncTbl = await nc_getTableSchema(aTbl_getTableName(k).tn);
// //
// // await importLTARData({
// // table: ncTbl,
// // projectName: syncDB.projectName,
// // api,
// // base,
// // fields: Object.values(tblLinkGroup).flat(),
// // logBasic
// // });
// for (const [k, v] of Object.entries(tblLinkGroup)) {
// const ncTbl = await nc_getTableSchema(aTbl_getTableName(k).tn);
//
// // not a migrated table, skip
// if (undefined === aTblSchema.find(x => x.name === ncTbl.title))
// continue;
//
// recordCnt = 0;
// await nocoReadDataSelected(
// syncDB.projectName,
// ncTbl,
// async (projName, table, record, _field) => {
// await nocoLinkProcessing(projName, table, record, _field);
// },
// v
// );
// }
}
} catch (error) {
logDetailed(
`There was an error while migrating data! Please make sure your API key (${syncDB.apiKey}) is correct.`

32
packages/nocodb/src/lib/services/sync/helpers/readAndProcessData.ts
Unescape View File

@ -115,12 +115,6 @@ export async function importData({
if (tempData.length >= BULK_DATA_BATCH_SIZE) {
let insertArray = tempData.splice(0, tempData.length);
// await api.dbTableRow.bulkCreate(
// 'nc',
// projectName,
// table.id,
// insertArray
// );
await bulkDataService.bulkDataInsert({
projectName: projectName,
@ -149,13 +143,6 @@ export async function importData({
readable.on('end', async () => {
await Promise.all(promises);
if (tempData.length > 0) {
// await api.dbTableRow.bulkCreate(
// 'nc',
// projectName,
// table.id,
// tempData
// );
await bulkDataService.bulkDataInsert({
projectName: projectName,
tableName: table.title,
@ -230,7 +217,6 @@ export async function importLTARData({
logBasic,
}));
// const modelMeta: any = await api.dbTable.read(table.id);
const modelMeta: any = await tableService.getTableWithAccessibleViews({
tableId: table.id,
user: syncDB.user,
@ -254,10 +240,6 @@ export async function importLTARData({
// mark as inserted
insertedAssocRef[colMeta.colOptions.fk_mm_model_id] = true;
// const assocModelMeta: TableType = (await api.dbTable.read(
// colMeta.colOptions.fk_mm_model_id
// )) as any;
const assocModelMeta: TableType =
(await tableService.getTableWithAccessibleViews({
tableId: colMeta.colOptions.fk_mm_model_id,
@ -316,13 +298,6 @@ export async function importLTARData({
)}`
);
// await api.dbTableRow.bulkCreate(
// 'nc',
// projectName,
// assocMeta.modelMeta.id,
// insertArray
// );
await bulkDataService.bulkDataInsert({
projectName: projectName,
tableName: table.title,
@ -351,13 +326,6 @@ export async function importLTARData({
)}`
);
// await api.dbTableRow.bulkCreate(
// 'nc',
// projectName,
// assocMeta.modelMeta.id,
// assocTableData
// );
await bulkDataService.bulkDataInsert({
projectName: projectName,
tableName: table.title,

Write Preview
Loading…
Cancel
Save