github
/
nocodb
mirror of https://github.com/nocodb/nocodb
1
0
Fork 0
Code Issues Releases Wiki Activity
多维表格
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
397 Commits
135 Branches
271 Tags
1.2 GiB
 
 
 
 
 
 
Tree: 3b0d3a4f18
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '3b0d3a4f18'
${ noResults }
nocodb/packages/nc-gui/store/sqlMgr.js

464 lines
13 KiB
Raw Blame History

// const {SqlMgr} = require("electron").remote.require("./libs");
import headers from "../components/apiClient/headers";
// let sqlMgrSingleton = null;
// import axios from 'axios';
//
// if (!this.$axios) {
// this.$axios = axios.create({
// baseURL: 'http://localhost:8080',
// });
// }
//
// const this.$axios = this.$axios;
function translateUiToLibCall(args, op, opArgs) {
let data = {
type: null,
module: null,
title: null
}
switch (op) {
case 'projectCreate1':
data.type = "Create";
data.title = opArgs.project.title;
data.module = "Project";
break;
case 'projectReadByFolder':
data.type = "Reading";
data.title = '';
data.module = "Project";
break;
case 'tableCreate':
data.type = "Create";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'tableList':
data.api = 'DB_TABLE_LIST'
data.type = "List";
data.title = 'list';
data.module = "table";
break;
case 'tableUpdate':
data.type = "Update";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'tableDelete':
data.type = "Delete";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'viewCreate':
data.type = "Create";
data.title = opArgs._tn || opArgs.view_name;
data.module = "View";
break;
case 'viewList':
data.type = "List";
data.title = opArgs._tn || opArgs.view_name;
data.module = "View";
break;
case 'viewUpdate':
data.type = "Update";
//data.title = opArgs.view_name;
data.module = "View";
break;
case 'viewDelete':
data.type = "Delete";
data.title = opArgs._tn || opArgs.view_name;
data.module = "View";
break;
case 'functionCreate':
data.type = "Create";
data.title = opArgs.function_name;
data.module = "Function";
break;
case 'functionList':
data.type = "";
//data.title = opArgs.function_name;
data.module = "Function";
break;
case 'functionUpdate':
data.type = "Update";
data.title = opArgs.function_name;
data.module = "Function";
break;
case 'functionDelete':
data.type = "Delete";
data.title = opArgs.function_name;
data.module = "Function";
break;
case 'procedureCreate':
data.type = "Create";
data.title = opArgs.procedure_name;
data.module = "Procedure";
break;
case 'procedureList':
data.type = "List";
//data.title = opArgs.procedure_name;
data.module = "Procedure";
break;
case 'procedureUpdate':
data.type = "Update";
data.title = opArgs.procedure_name;
data.module = "Procedure";
break;
case 'procedureDelete':
data.type = "Delete";
data.title = opArgs.procedure_name;
data.module = "Procedure";
break;
case 'sequenceCreate':
data.type = "Create";
data.title = opArgs.sequence_name;
data.module = "Sequence";
break;
case 'sequenceList':
data.type = "List";
//data.title = opArgs.sequence_name;
data.module = "Sequence";
break;
case 'sequenceUpdate':
data.type = "Update";
data.title = opArgs.sequence_name;
data.module = "Sequence";
break;
case 'sequenceDelete':
data.type = "Delete";
data.title = opArgs.sequence_name;
data.module = "Sequence";
break;
case 'triggerCreate':
data.type = "Create ";
data.title = opArgs._tn || opArgs.tn;
data.module = "trigger";
break;
case 'triggerList':
data.type = "Create ";
//data.title = opArgs.trigger_name;
data.module = "trigger";
break;
case 'triggerUpdate':
data.type = "Update ";
data.title = opArgs.trigger_name;
data.module = "trigger";
break;
case 'triggerDelete':
data.type = "Delete ";
data.title = opArgs.trigger_name;
data.module = "trigger";
break;
case 'indexCreate':
data.type = "Create Index on ";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'indexList':
data.type = "List";
//data.title = opArgs.tn;
data.module = "table";
break;
case 'indexUpdate':
data.type = "Update Index on ";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'indexDelete':
data.type = "Delete Index on ";
data.title = opArgs._tn || opArgs.tn;
data.module = "table";
break;
case 'rowCreate':
data.type = "";
data.title = opArgs;
data.module = "";
break;
case 'rowList':
data.type = "List";
data.title = opArgs;
data.module = "";
break;
case 'rowUpdate':
data.type = "";
data.title = opArgs;
data.module = "";
break;
case 'rowDelete':
data.type = "";
data.title = opArgs;
data.module = "";
break;
case 'seedInit':
data.type = "Init";
data.title = '';
data.module = "Seed";
break;
case 'seedTerm':
data.type = "Term";
data.title = '';
data.module = "Seed";
break;
case 'seedStart':
data.type = "Start";
data.title = '';
data.module = "Seed";
break;
case 'seedStop':
data.type = "Stop";
data.title = '';
data.module = "Seed";
break;
case 'seedSettingsRead':
data.type = "Settings";
data.title = '';
data.module = "Seed";
break;
case 'seedSettingsCreate':
data.type = "Settings Create";
data.title = '';
data.module = "Seed";
break;
case 'projectGenerateBackend':
data.type = "Generate Code";
data.title = '';
data.module = "Project";
break;
case 'projectGenerateBackendGql':
data.type = "Generate GraphQL Code";
data.title = '';
data.module = "Project";
break;
case 'tableRename':
data.type = "Table rename";
data.title = '';
data.module = "";
break;
case 'relationCreate':
case 'xcVirtualRelationCreate':
data.type = "Relation create";
data.title = '';
data.module = "";
break;
case 'relationDelete':
case 'xcVirtualRelationDelete':
data.type = "Relation delete";
data.title = '';
data.module = "";
break;
default:
throw new Error(`Should not have occurred ${op}`);
}
return data;
}
export const state = () => ({
sqlMgr: null
});
export const mutations = {
set(state, sqlMgrSingleton) {
state.sqlMgr = sqlMgrSingleton;
},
};
export const getters = {
// sqlMgr(state) {
// return state.sqlMgr;
// }
};
export const actions = {
//
// async instantiateSqlMgr({commit, state, ...rest}, data) {
// console.log(this)
// if (!state.sqlMgr) {
// sqlMgrSingleton = new SqlMgr(rest);
// console.log(
// "\n\n************************sqlMgr is created************************\n\n."
// );
// commit("set", sqlMgrSingleton);
// } else {
// console.log("sqlMgr is already instantiated.");
// console.log(state.sqlMgr);
// }
// return state.sqlMgr;
// },
async ActSqlOpPlus({commit, state, dispatch, rootState}, [args, op, opArgs]) {
const params = {};
if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
params.project_id = this.$router.currentRoute.params.project_id;
}
let data = translateUiToLibCall(args, op, opArgs);
commit('notification/MutListAdd', {status: 'pending', ...data}, {root: true});
const headers = {};
if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
headers['xc-master-key'] = rootState.users.masterKey || '';
} else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
headers['xc-auth'] = rootState.users.token || '';
}
try {
let result = null;
if (data.module === 'Project') {
result = await dispatch('ActSqlOp', [args, op, opArgs]);
} else if (data.module === 'Seed' || (data.title || '').toLowerCase() === 'list' || data.type.toLowerCase() === 'list') {
result = await dispatch('ActSqlOp', [args, op, opArgs]);
} else {
console.log(data);
// result = await state.sqlMgr.sqlOpPlus(args, op, opArgs);
result = (await this.$axios({
url: '?q=sqlOpPlus_' + op,
baseURL: process.env.NODE_ENV === 'production' ? './' : 'http://localhost:8080/dashboard',
// baseURL: 'http://localhost:8080/dashboard',
data: {api: op, ...args, ...params, args: opArgs, sqlOpPlus: true},
headers,
method: 'post'
}
)).data;
}
commit('notification/MutListRemove', {status: 'success', ...data}, {root: true});
return result;
} catch (e) {
commit('notification/MutListRemove', {status: 'error', ...data}, {root: true});
throw e;
}
},
async ActSqlOp({commit, state, rootState}, [args, op, opArgs, cusHeaders, cusAxiosOptions, queryParams]) {
const params = {};
if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
params.project_id = this.$router.currentRoute.params.project_id;
}
try {
const headers = {};
if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
headers['xc-master-key'] = rootState.users.masterKey;
} else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
headers['xc-auth'] = rootState.users.token;
}
if (cusHeaders) {
Object.assign(headers, cusHeaders)
}
return (await this.$axios({
url: '?q=sqlOp_' + op,
baseURL: process.env.NODE_ENV === 'production' ? './' : 'http://localhost:8080/dashboard',
// baseURL: 'http://localhost:8080/dashboard',
data: {api: op, ...args, ...params, args: opArgs},
headers,
method: 'post',
params: (args && args.query) || {},
...(cusAxiosOptions || {}),
})).data;
} catch (e) {
const err = new Error(e.response.data.msg);
err.response = e.response;
throw err;
}
},
async ActUpload({commit, state, rootState}, [args, op, opArgs, file, cusHeaders, cusAxiosOptions]) {
try {
const params = {};
if (this.$router.currentRoute && this.$router.currentRoute.params && this.$router.currentRoute.params.project_id) {
params.project_id = this.$router.currentRoute.params.project_id;
}
const headers = {
'Content-Type': 'multipart/form-data'
};
if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'masterKey') {
headers['xc-master-key'] = rootState.users.masterKey;
} else if (rootState.project.projectInfo && rootState.project.projectInfo.authType === 'jwt') {
headers['xc-auth'] = rootState.users.token;
}
if (cusHeaders) {
Object.assign(headers, cusHeaders)
}
const formData = new FormData();
formData.append("file", file);
formData.append('json', JSON.stringify({api: op, ...params, ...args, args: opArgs}));
// formData.append('project_id', params.project_id);
return (await this.$axios({
url: '?q=sqlOp_' + op,
baseURL: process.env.NODE_ENV === 'production' ? './' : 'http://localhost:8080/dashboard',
// baseURL: 'http://localhost:8080/dashboard',
data: formData, //{api: op, ...args, args: opArgs},
headers,
method: 'post',
params: {project_id: params.project_id, ...((args && args.query) || {})},
...(cusAxiosOptions || {})
})).data;
} catch (e) {
throw new Error(e.response.data.msg);
}
},
};
/**
* @copyright Copyright (c) 2021, Xgene Cloud Ltd
*
* @author Naveen MR <oof1lab@gmail.com>
* @author Pranav C Balan <pranavxc@gmail.com>
*
* @license GNU AGPL version 3 or any later version
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/