dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-20 21:46:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

file formats refactor

Browse Source
This commit is contained in:
Jan Prochazka
2020-11-19 07:59:03 +01:00
parent ef3c96f574
commit ac049f43a3
11 changed files with 76 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
packages/web/src/impexp/createImpExpScript.js
View File

@@ -4,17 +4,18 @@ import getAsArray from '../utility/getAsArray';
import { getConnectionInfo } from '../utility/metadataLoaders';
import engines from 'dbgate-engines';
import { findObjectLike } from 'dbgate-tools';
import { findFileFormat } from '../fileformats';
export function getTargetName(source, values) {
const key = `targetName_${source}`;
if (values[key]) return values[key];
if (values.targetStorageType == 'csv') return `${source}.csv`;
if (values.targetStorageType == 'jsonl') return `${source}.jsonl`;
const format = findFileFormat(values.targetStorageType);
if (format) return `${source}.${format.extension}`;
return source;
}
export function isFileStorage(storageType) {
return storageType == 'csv' || storageType == 'jsonl' || storageType == 'excel';
return !!findFileFormat(storageType);
}
async function getConnection(storageType, conid, database) {
@@ -55,14 +56,9 @@ function getSourceExpr(sourceName, values, sourceConnection, sourceDriver) {
}
if (isFileStorage(sourceStorageType)) {
const sourceFile = values[`sourceFile_${sourceName}`];
if (sourceStorageType == 'excel') {
return ['excelSheetReader', sourceFile];
}
if (sourceStorageType == 'jsonl') {
return ['jsonLinesReader', sourceFile];
}
if (sourceStorageType == 'csv') {
return ['csvReader', sourceFile];
const format = findFileFormat(sourceStorageType);
if (format && format.readerFunc) {
return [format.readerFunc, sourceFile];
}
}
if (sourceStorageType == 'jsldata') {
@@ -101,21 +97,15 @@ function getFlagsFroAction(action) {
function getTargetExpr(sourceName, values, targetConnection, targetDriver) {
const { targetStorageType } = values;
if (targetStorageType == 'csv') {
const format = findFileFormat(targetStorageType);
if (format && format.writerFunc) {
return [
'csvWriter',
{
fileName: getTargetName(sourceName, values),
},
];
}
if (targetStorageType == 'jsonl') {
return [
'jsonLinesWriter',
format.writerFunc,
{
fileName: getTargetName(sourceName, values),
},
];
}
if (targetStorageType == 'database') {
return [