+
+
-
+
+ 新建连接
+
+
+
+
+
+ {{ link.name }}
+ {{ link.version }}
+
+ 
+ {{ db.name }}
+ 
+
+
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
-
- 新建连接
-
-
-
-
- {{link.name}}
- {{link.version}}
-
-
- {{db.name}}
-
-
-
-
-
-
-
-
- 
- 
-
-
-
-
-
-
-
- {{db.name}}
-
-
+
+
+ 
+
+
+
+
+
+
+
+
+ {{ db.name }}
+
+
-
-
-
-
- 超级表名
- 
- {{ scope.row.name }}
-
-
-
-
-
-
-
+
+
+
+
+
-
-
-
-
-
-
- 
- 
-
-
-
-
- 
-
-
-
-
-
- {{ scope.row.name }}
-
-
-
-
-
-
-
-
+
+
+
+
+ 超级表名
+
+ {{ scope.row.name }}
+
+
+
+
+
+
+
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ scope.row.name }}
+
+
+
+
+
+
+
-
-
-
-
-
-
-
- 全选
- 反选
-
-
-
-
- {{label}}
-
-
-
-
-
-
-
- 10
- 15
- 20
-
-
-
-
-
-
-
-
-
-
-
- 时间范围:
-
-
-
-
+
-
-
-
-
-
-
` - info += `创建时间: ${item['created_time']}
` - info += `可更新: ${item['update'] == 0?'否':'是'}
` - info += `cache(MB): ${item['cache(MB)']}
` - info += `cachelast: ${item['cachelast']}
` - info += `comp: ${item['comp']}
` - info += `days: ${item['days']}
` - info += `fsync: ${item['fsync']}
` - info += `keep0,keep1,keep(D): ${item['keep0,keep1,keep(D)']}
` - info += `maxrows: ${item['maxrows']}
` - info += `minrows: ${item['minrows']}
` - info += `ntables: ${item['ntables']}
` - info += `quorum: ${item['quorum']}
` - info += `replica: ${item['replica']}
` - info += `status: ${item['status']}
` - info += `vgroups: ${item['vgroups']}
` - info += `wallevel: ${item['wallevel']}
` - info += `precision: ${item['precision']}
` - } - }) - return info - }, - alartDB(link,dbName){ - //切换数据库前先清空表 - this.dbInfo=this.makeDbInfo(link.dbs,dbName) - this.surperTables = [] - this.clearSurperTable() - this.tables = [] - this.clearTable() - - //记录进入的数据库 - this.theLink = link - this.theDB = dbName - - //更新超级表页 - this.drawer = false - this.activeTab = "1" - this.freshSurperTables() - }, - searchSurperTList(){ - this.SuperTdialog = false - this.surperTables = [] - this.clearSurperTable() - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - TaosRestful.showSuperTables(this.theDB, payload, like=this.SuperTdialogText).then(data =>{ - if(data.res){ - //拉取超级表成功 - this.$message({ - message: '查找成功', - type: 'success', - duration:1000 - }); - this.surperTables = data.data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - this.freshSurperTables() - } - this.SuperTdialogText = "" - this.loadingSurperList = false - }) - - }, - freshSurperTList(){ - this.surperTables = [] - this.clearSurperTable() - this.freshSurperTables() - }, - searchTList(){ - this.Tdialog = false - this.tables = [] - this.clearTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - TaosRestful.showTables(this.theDB, payload, like=this.TdialogText).then(data =>{ - if(data.res){ - //拉取表成功 - this.$message({ - message: '查找成功', - type: 'success', - duration:1000 - }); - this.tables = data.data - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - this.freshTables() - - } - this.TdialogText = "" - this.loadingTableList = false - }) - }, - freshTList(){ - this.tables = [] - this.clearTable() - this.freshTables() - }, - clearSurperTable(){ - this.surperTableName = "" - this.totalSurperTable = 0 - this.surperTableData = [] - this.surperTableLabel = [] - this.surperTableFilter={ - fields:[], - surperDateRange:[], - surperTSearchText: "", - surperTSearchColumn: "", - } - }, - clearTable(){ - this.tableName = "" - this.totalTable = 0 - this.tableData = [] - this.tableLabel = [] - this.tableFilter={ - fields:[], - dateRange:[], - tableSearchText:"", - tableSearchColumn:"", - } - }, - freshSurperTables(){ - //清理超级表列表 - this.surperTables = [] - //清理选中的超级表和具体数据 - this.clearSurperTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - TaosRestful.showSuperTables(this.theDB, payload).then(data =>{ - if(data.res){ - //拉取超级表成功 - this.$message({ - message: '刷新成功', - type: 'success', - duration:1000 - }); - this.surperTables = data.data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingSurperList = false - }) - }, - freshTables(){ - //清理表列表 - this.tables = [] - //清理选中的表和具体数据 - this.clearTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - TaosRestful.showTables(this.theDB, payload).then(data =>{ - if(data.res){ - //拉取表成功 - this.$message({ - message: '刷新成功', - type: 'success', - duration:1000 - }); - this.tables = data.data - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingTableList = false - }) - }, - handleSwichTab(tab) { - switch(tab.name) { - case "1": - //超级表 - this.freshSurperTables() - break; - case "2": - //表 - this.freshTables() - break; - case "3": - //控制台 - break; - case "4": - //数据库属性 - break; - } - }, - openSurperTableFilterD(){ - this.surperTableFilterDialog = true - this.surperTableFilterCopy = JSON.parse(JSON.stringify(this.surperTableFilter)) - }, - concelSurperTableFilter(){ - this.$message({ - message: '取消操作', - type: 'warning', - duration:1000 - }); - this.surperTableFilterDialog = false - this.surperTableFilter = this.surperTableFilterCopy - }, - postSurperTableFilter(){ - this.surperTableFilterDialog = false - this.selectSurperData(false) - }, - openTableFilterD(){ - this.tableFilterDialog = true - this.tableFilterCopy = JSON.parse(JSON.stringify(this.tableFilter)) - }, - concelTableFilter(){ - this.$message({ - message: '取消操作', - type: 'warning', - duration:1000 - }); - this.tableFilterDialog = false - this.tableFilter = this.tableFilterCopy - }, - postTableFilter(){ - this.tableFilterDialog = false - this.selectTData(false) - }, - searchSurperText(){ - if(this.surperTableFilter.surperTSearchColumn && this.surperTableFilter.surperTSearchText.trim()){ - // this.surperWhere = this.surperTSearchColumn + " > " + this.surperTSearchText.trim()+"%" - // this.clearSurperTable() - let surperTSearchText = this.surperTableFilter.surperTSearchText.trim() - if(!isNaN(surperTSearchText)){ - this.surperWhere =this.surperTableFilter.surperTSearchColumn + " = " + surperTSearchText - } else { - this.surperWhere =this.surperTableFilter.surperTSearchColumn + " = '" + surperTSearchText +"'" - } - - this.selectSurperData(false) - } else { - this.surperWhere = "" - this.$message({ - message: '请填写正确', - type: 'warning', - duration:1000 - }); - this.selectSurperData(false) - } - }, - searchTableText(){ - if(this.tableFilter.tableSearchColumn && this.tableFilter.tableSearchText.trim()){ - - let tableSearchText = this.tableFilter.tableSearchText.trim() - if(!isNaN(tableSearchText)){ - this.tableWhere =this.tableFilter.tableSearchColumn + " = " + tableSearchText - } else { - this.tableWhere =this.tableFilter.tableSearchColumn + " = '" + tableSearchText +"'" - } - - this.selectTData(false) - } else { - this.tableWhere = "" - this.$message({ - message: '请填写正确', - type: 'warning', - duration:1000 - }); - this.selectTData(false) - } - }, - selectSurperData(isFirst, isResetPage){ - - //处理时间范围 - let startTime = null - let endTime = null - if(this.surperTableFilter.surperDateRange){ - startTime = this.surperTableFilter.surperDateRange[0]; - endTime = this.surperTableFilter.surperDateRange[1]; - } - - //是否需要重置分页 - if(isResetPage){ - this.currentPageSurperTable = 1 - } - - let offsetVal = (this.currentPageSurperTable-1)*this.eachPageSurperTable - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperTable = true - - //处理查询数据 - // if(!this.surperTableFilter.surperTSearchText.trim()){ - // this.surperWhere = "" - // } - - //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null - TaosRestful.selectData(this.surperTableName, this.theDB, payload, fields=this.surperTableFilter.fields, where=this.surperWhere - , limit=this.eachPageSurperTable, offset=offsetVal, desc=this.surperTorder, startTime=startTime, endTime=endTime) - .then(data =>{ - if(data.res){ - //成功 - if(data.data.length != 0){ - //有数据 - this.$message({ - message: '获取成功', - type: 'success', - duration:1000 - }); - if(isFirst){ - this.surperTableLabelItems = Object.keys(data.data[0]) - } - this.surperTableLabel = Object.keys(data.data[0]) - this.surperTableFilter.fields = Object.keys(data.data[0]) - this.surperTableData = data.data - this.totalSurperTable = data.count - } else { - this.surperTableLabel = [] - this.surperTableData = data.data - this.totalSurperTable = data.count - this.$message({ - message: '无数据', - type: 'warning', - duration:1000 - }); - } - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingSurperTable = false - - }) - }, - selectTData(isFirst, isResetPage=false){ - - //处理时间范围 - let startTime = null - let endTime = null - if(this.tableFilter.dateRange){ - startTime = this.tableFilter.dateRange[0]; - endTime = this.tableFilter.dateRange[1]; - } - - if(isResetPage){ - this.currentPageTable = 1 - } - - let offsetVal = (this.currentPageTable-1)*this.eachPageTable - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTable = true - - // if(!this.tableFilter.tableSearchText.trim()){ - // this.tableWhere = "" - // } - - //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null - TaosRestful.selectData(this.tableName, this.theDB, payload, fields=this.tableFilter.fields, where=this.tableWhere - , limit=this.eachPageTable, offset=offsetVal, desc=this.Torder, startTime=startTime, endTime=endTime) - .then(data =>{ - if(data.res){ - //成功 - if(data.data.length != 0){ - //有数据 - this.$message({ - message: '获取成功', - type: 'success', - duration:1000 - }); - if(isFirst){ - this.tableLabelItems = Object.keys(data.data[0]) - } - this.tableLabel = Object.keys(data.data[0]) - this.tableFilter.fields = Object.keys(data.data[0]) - this.tableData = data.data - this.totalTable = data.count - } else { - this.tableLabel = [] - this.tableData = data.data - this.totalTable = data.count - this.$message({ - message: '无数据', - type: 'warning', - duration:1000 - }); - } - } - this.loadingTable = false - }) - }, - surTableFilter(){ - this.selectSurperData(0) - }, - handleClickSurperT(val) { - if(val){ - this.clearSurperTable() - this.surperTableName = val.name - this.selectSurperData(true) - } - }, - handleClickT(val) { - if(val){ - this.clearTable() - this.tableName = val.table_name - this.selectTData(true) - } - }, - paginationSurperChange(){ - this.selectSurperData(false) - }, - paginationChange(){ - this.selectTData(false) - }, - editSurperT(val) { - console.log(val) - }, - deleteSurperT(val) { - this.$confirm('确认删除超级表' + val + "吗？") - .then(_ => { - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - - //TODO没测试过 - TaosRestful.dropTable(val, this.theDB, payload).then(data => { - - if(data.res){ - //成功 - this.$message({ - message: '删除成功', - type: 'success', - duration:500 - }); - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:500 - }); - } - this.loadingSurperList = false - this.freshSurperTables() - }) - - }) - .catch(_ => { - this.$message({ - message: '操作已取消', - type: 'warning', - duration:500 - }); - }); - }, - editT(val) { - console.log(val) - }, - deleteT(val) { - this.$confirm('确认删除表' + val + "吗？") - .then(_ => { - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - - //TODO没测试过 - TaosRestful.dropTable(val, this.theDB, payload).then(data => { - - if(data.res){ - //成功 - this.$message({ - message: '删除成功', - type: 'success', - duration:500 - }); - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:500 - }); - } - this.loadingTableList = false - this.freshTables() - }) - - }) - .catch(_ => { - this.$message({ - message: '操作已取消', - type: 'warning', - duration:500 - }); - }); - }, - sendSQL(){ - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - // console.log(this.theDB) - TaosRestful.rawSqlWithDB(this.consoleInput,this.theDB,payload).then(data => { - if(data.res){ - // let info = '' - // info += `数据数量: ${data.count}
` - // info += `数据列: ${data.head}
` - // info += `数据: ${data.data}
` - this.$message({ - message: '执行成功', - type: 'success', - duration:500 - }); - this.consoleResult = data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - - }) - }, - closeSuperTdialog(){ - this.SuperTdialogText = "" - this.SuperTdialog = false - }, - closeTdialog(){ - this.TdialogText = "" - this.Tdialog = false - }, - STChooseAll(){ - this.surperTableFilter.fields = this.surperTableLabelItems - }, - STChooseReverse(){ - let newFields = this.surperTableLabelItems.filter((item) => { - return this.surperTableFilter ? this.surperTableFilter.fields.indexOf(item) == -1 : false; - }) - this.surperTableFilter.fields = newFields - }, - TChooseAll(){ - this.tableFilter.fields = this.tableLabelItems - }, - TChooseReverse(){ - let newFields = this.tableLabelItems.filter((item) => { - return this.tableLabelItems.fields? this.tableLabelItems.fields.indexOf(item) == -1: false; - }) - this.tableFilter.fields = newFields - } - - } - }) - - - \ No newline at end of file diff --git a/renderer/js/electronStore.js b/renderer/js/electronStore.js new file mode 100644 index 0000000..69052f7 --- /dev/null +++ b/renderer/js/electronStore.js @@ -0,0 +1,42 @@ +//持久化存储 +const Store = require('electron-store'); + +let store = new Store(); + +const getLinks = () => { + let links = store.get("links"); + links = links ? links : [] + return links; +} + +const setLinks = (links) => { + return store.set("links", links); +} + +const deleteALink = (key) => { + let links = getLinks(); + links.splice(key, 1) + return setLinks(links) +} + +const addALink = (link) => { + //添加一个连接，如果本地存了，就更新，没存新增 + let links = getLinks() + for (let i = 0; i < links.length; i++) { + if (link.host === links[i].host && link.port === links[i].port) { + //更新 + links[i] = link + return setLinks(links) + } + } + //新增 + links.push(link) + return setLinks(links) +} + +Vue.prototype.$electronStore = { + getLinks, + setLinks, + deleteALink, + addALink +}; diff --git a/renderer/js/index.js b/renderer/js/index.js new file mode 100644 index 0000000..119ba9d --- /dev/null +++ b/renderer/js/index.js @@ -0,0 +1,915 @@ +const TaosRestful = require('./taosrestful_.js') +require('./electronStore.js') +const {TouchBarScrubber} = require('electron') + +new Vue({ + el: '#app', + mounted: function () { + let _this = this; + this.$data.links = this.$electronStore.getLinks() + this.$nextTick(() => { + window.onresize = function listen() { + _this.contentTableHeight = window.innerHeight * 0.74; + } + }) + }, + data: function () { + return { + dbInfo: '', + consoleResult: '', + loadingLinks: false, + drawer: true, + addLinkDialog: false, + addOrEditTitle: '新建连接', + linkForm: { + name: "", + host: "", + port: "", + user: "", + password: "", + }, + activeTab: "1", + + surperTableFilterCopy: {}, + + surperTableFilter: { + fields: [], + surperDateRange: [], + surperTSearchText: "", + surperTSearchColumn: "", + }, + + tableFilterCopy: {}, + tableFilter: { + fields: [], + dateRange: [], + tableSearchText: "", + tableSearchColumn: "", + }, + surperWhere: "", + tableWhere: "", + + tableFilterDialog: false, + surperTableFilterDialog: false, + + contentTableHeight: window.innerHeight * 0.74, + + surperTables: [], //超级表list + surperTableData: [], + surperTableName: "", + totalSurperTable: 0, + surperTableLabelItems: [], + surperTableLabel: [], + loadingSurperList: false, + loadingSurperTable: false, + + tables: [], //表list + tableData: [], + tableName: "", + totalTable: 0, + tableLabelItems: [], + tableLabel: [], + loadingTableList: false, + loadingTable: false, + + eachPageSurperTable: 30, + currentPageSurperTable: 1, + eachPageTable: 30, + currentPageTable: 1, + + addDBDialogLinkKey: 0, + addDBDialog: false, + addDBname: "", + addDBcomp: "", + addDBreplica: "", + addDBkeep: "", + addDBupdate: "", + addDBquorum: "", + addDBblocks: "", + + searchIcon: true, + freshIcon: true, + links: [], + theLink: {}, //当前连接 + theDB: "", //当前数据库 + + SuperTdialog: false, + SuperTdialogText: "", + Tdialog: false, + TdialogText: "", + + surperTorder: "ASC", + Torder: "ASC", + consoleInput: "", + marks: { + 0: '0', + 365: '365', + 36500: '36500' + } + } + }, + methods: { + beforeClosedrawer() { + if (this.theDB) { + this.drawer = false + } else { + this.$message({ + message: '请选择数据库', + type: 'warning', + duration: 1000 + }); + } + }, + cancelAddLink() { + this.addLinkDialog = false + this.addOrEditTitle = '新建连接' + this.clearLinkForm(); + }, + clearLinkForm() { + //清空表单 + this.linkForm = { + name: "", + host: "", + port: "", + user: "", + password: "" + } + }, + formatBoolean(data) { + data.forEach(item => { + for (let i in item) { + if (item[i] === true) { + item[i] = 'true' + } else if (item[i] === false) { + item[i] = 'false' + } + } + }) + }, + /** 复制代码成功 */ + clipboardSuccess() { + this.$message({ + message: '复制成功', + type: 'success', + duration: 500 + }); + }, + confirmAddLink(event) { + //新建连接，先连接，如果成功，将payload+name记入本地 + //var tr = new TaosRestful("121.36.56.117","6041","root","msl110918") + let payload = { + ip: this.linkForm.host, + port: this.linkForm.port, + user: this.linkForm.user, + password: this.linkForm.password + } + TaosRestful.showDatabases(payload).then(data => { + //处理返回的数据库数据 + if (data.res) { + + TaosRestful.getVersion(payload).then(_data => { + //连接成功，保存到本地 + this.$electronStore.addALink({ + name: this.linkForm.name, + host: this.linkForm.host, + port: this.linkForm.port, + user: this.linkForm.user, + password: this.linkForm.password, + version: _data + }) + //更新连接列表 + this.links = this.$electronStore.getLinks() + //关闭新建连接的弹窗 + this.addLinkDialog = false + this.addOrEditTitle = '新建连接' + //清空表单 + this.clearLinkForm(); + }) + } else { + //连接失败 + this.$message({ + message: '连接失败', + type: 'error', + duration: 1000 + }); + } + } + ) + }, + deleteLink(key, linkName) { + this.$confirm('确认删除连接' + linkName + "吗？") + .then(_ => { + this.$electronStore.deleteALink(key) + this.links = this.$electronStore.getLinks() + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + }) + }, + freshDB(key) { + let _this = this; + let theLink = this.links[key] + let payload = { + ip: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password + } + this.loadingLinks = true + TaosRestful.showDatabases(payload).then(data => { + this.loadingLinks = false + if (data.res) { + this.$message({ + message: '刷新成功', + type: 'success', + duration: 1000 + }); + this.links[key].dbs = data.data + + TaosRestful.getVersion(payload).then(data => { + theLink.version = data + _this.$data.links[key] = theLink + if (TaosRestful.compareVersion(data, theLink.version)) { + this.$electronStore.addALink({ + name: theLink.name, + host: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password, + version: data + }) + } + }) + + //TODO展开菜单 + + } else { + //连接失败，直接提示 + this.$message({ + message: "连接失败，请稍后重试", + type: 'error', + duration: 1000 + }); + } + }) + }, + addDB(key) { + this.addDBDialogLinkKey = key + this.addDBDialog = true + + this.addDBname = "" + this.addDBcomp = 2 + this.addDBreplica = 1 + this.addDBkeep = 3650 + this.addDBupdate = 0 + this.addDBquorum = 1 + this.addDBblocks = 6 + }, + editDB(key) { + let theLink = this.links[key] + this.linkForm = { + name: theLink.name, + host: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password, + } + this.addOrEditTitle = '编辑连接' + this.addLinkDialog = true + }, + postaddDB() { + let key = this.addDBDialogLinkKey + let theLink = this.links[key] + let payload = { + ip: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password + } + if (this.addDBname) { + if (this.addDBreplica && this.addDBquorum) { + if (this.addDBreplica < this.addDBquorum) { + this.$message({ + message: 'replica应大于等于quorum', + type: 'error', + duration: 1000 + }); + return + } + } + TaosRestful.createDatabase(this.addDBname, payload, safe = true, keep = this.addDBkeep, + update = this.addDBupdate, comp = this.addDBcomp, replica = this.addDBreplica, + quorum = this.addDBquorum, blocks = this.addDBblocks, theLink.version).then(data => { + if (data.res) { + //新增成功 + this.$message({ + message: '添加成功', + type: 'success', + duration: 1000 + }); + this.freshDB(key) + this.addDBDialog = false + } else { + //添加失败 + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + }) + } else { + this.$message({ + message: '请填写内容', + type: 'warning', + duration: 1000 + }); + } + }, + deleteDB(link, dbName, key) { + this.$confirm('确认删除数据库' + dbName + "吗？") + .then(_ => { + let payload = { + ip: link.host, + port: link.port, + user: link.user, + password: link.password + } + this.loadingLinks = true + + TaosRestful.dropDatabase(dbName, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 1000 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingLinks = false + this.freshDB(key) + }) + }) + }, + makeDbInfo(dbs, dbName) { + // console.log(dbs) + let info = '无法获取数据库信息' + dbs.forEach(item => { + if (item['name'] === dbName) { + info = `数据库名: ${dbName}
` + info += `创建时间: ${item['created_time']}
` + info += `update: ${item['update'] > 0 ? (item['update'] === 1 ? '允许整行更新' : '允许部分列更新' ) : '不允许更新'}
` + info += `cache(MB): ${item['cache(MB)']}
` + info += `cachelast: ${item['cachelast']}
` + info += `comp: ${item['comp']}
` + info += `days: ${item['days']}
` + info += `fsync: ${item['fsync']}
` + info += `keep1,keep2,keep(D): ${item['keep1,keep2,keep(D)']}
` + info += `maxrows: ${item['maxrows']}
` + info += `minrows: ${item['minrows']}
` + info += `ntables: ${item['ntables']}
` + info += `quorum: ${item['quorum']}
` + info += `replica: ${item['replica']}
` + info += `status: ${item['status']}
` + info += `vgroups: ${item['vgroups']}
` + info += `wallevel: ${item['wallevel']}
` + info += `precision: ${item['precision']}
` + } + }) + return info + }, + alartDB(link, dbName) { + //切换数据库前先清空表 + this.dbInfo = this.makeDbInfo(link.dbs, dbName) + this.surperTables = [] + this.clearSurperTable() + this.tables = [] + this.clearTable() + + //记录进入的数据库 + this.theLink = link + this.theDB = dbName + + //更新超级表页 + this.drawer = false + this.activeTab = "1" + this.freshSurperTables() + }, + searchSurperTList() { + this.SuperTdialog = false + this.surperTables = [] + this.clearSurperTable() + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + TaosRestful.showSuperTables(this.theDB, payload, like = this.SuperTdialogText).then(data => { + if (data.res) { + //拉取超级表成功 + this.$message({ + message: '查找成功', + type: 'success', + duration: 1000 + }); + this.surperTables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + this.freshSurperTables() + } + this.SuperTdialogText = "" + this.loadingSurperList = false + }) + + }, + freshSurperTList() { + this.surperTables = [] + this.clearSurperTable() + this.freshSurperTables() + }, + searchTList() { + this.Tdialog = false + this.tables = [] + this.clearTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + TaosRestful.showTables(this.theDB, payload, like = this.TdialogText).then(data => { + if (data.res) { + //拉取表成功 + this.$message({ + message: '查找成功', + type: 'success', + duration: 1000 + }); + this.tables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + this.freshTables() + + } + this.TdialogText = "" + this.loadingTableList = false + }) + }, + freshTList() { + this.tables = [] + this.clearTable() + this.freshTables() + }, + clearSurperTable() { + this.surperTableName = "" + this.totalSurperTable = 0 + this.surperTableData = [] + this.surperTableLabel = [] + this.surperTableFilter = { + fields: [], + surperDateRange: [], + surperTSearchText: "", + surperTSearchColumn: "", + } + }, + clearTable() { + this.tableName = "" + this.totalTable = 0 + this.tableData = [] + this.tableLabel = [] + this.tableFilter = { + fields: [], + dateRange: [], + tableSearchText: "", + tableSearchColumn: "", + } + }, + freshSurperTables() { + //清理超级表列表 + this.surperTables = [] + //清理选中的超级表和具体数据 + this.clearSurperTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + TaosRestful.showSuperTables(this.theDB, payload).then(data => { + if (data.res) { + this.surperTables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingSurperList = false + }) + }, + freshTables() { + //清理表列表 + this.tables = [] + //清理选中的表和具体数据 + this.clearTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + TaosRestful.showTables(this.theDB, payload).then(data => { + if (data.res) { + this.tables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingTableList = false + }) + }, + handleSwichTab(tab) { + switch (tab.name) { + case "1": + //超级表 + this.freshSurperTables() + break; + case "2": + //表 + this.freshTables() + break; + case "3": + //控制台 + break; + case "4": + //数据库属性 + break; + } + }, + openSurperTableFilterD() { + this.surperTableFilterDialog = true + this.surperTableFilterCopy = JSON.parse(JSON.stringify(this.surperTableFilter)) + }, + concelSurperTableFilter() { + this.surperTableFilterDialog = false + this.surperTableFilter = this.surperTableFilterCopy + }, + postSurperTableFilter() { + this.surperTableFilterDialog = false + this.selectSurperData(false) + }, + openTableFilterD() { + this.tableFilterDialog = true + this.tableFilterCopy = JSON.parse(JSON.stringify(this.tableFilter)) + }, + concelTableFilter() { + this.tableFilterDialog = false + this.tableFilter = this.tableFilterCopy + }, + postTableFilter() { + this.tableFilterDialog = false + this.selectTData(false) + }, + searchSurperText() { + if (this.surperTableFilter.surperTSearchColumn && this.surperTableFilter.surperTSearchText.trim()) { + // this.surperWhere = this.surperTSearchColumn + " > " + this.surperTSearchText.trim()+"%" + // this.clearSurperTable() + let surperTSearchText = this.surperTableFilter.surperTSearchText.trim() + if (!isNaN(surperTSearchText)) { + this.surperWhere = this.surperTableFilter.surperTSearchColumn + " = " + surperTSearchText + } else { + this.surperWhere = this.surperTableFilter.surperTSearchColumn + " = '" + surperTSearchText + "'" + } + + this.selectSurperData(false) + } else { + this.surperWhere = "" + this.$message({ + message: '请填写正确', + type: 'warning', + duration: 1000 + }); + this.selectSurperData(false) + } + }, + searchTableText() { + if (this.tableFilter.tableSearchColumn && this.tableFilter.tableSearchText.trim()) { + + let tableSearchText = this.tableFilter.tableSearchText.trim() + if (!isNaN(tableSearchText)) { + this.tableWhere = this.tableFilter.tableSearchColumn + " = " + tableSearchText + } else { + this.tableWhere = this.tableFilter.tableSearchColumn + " = '" + tableSearchText + "'" + } + + this.selectTData(false) + } else { + this.tableWhere = "" + this.$message({ + message: '请填写正确', + type: 'warning', + duration: 1000 + }); + this.selectTData(false) + } + }, + selectSurperData(isFirst, isResetPage) { + + //处理时间范围 + let startTime = null + let endTime = null + if (this.surperTableFilter.surperDateRange) { + startTime = this.surperTableFilter.surperDateRange[0]; + endTime = this.surperTableFilter.surperDateRange[1]; + } + + //是否需要重置分页 + if (isResetPage) { + this.currentPageSurperTable = 1 + } + + let offsetVal = (this.currentPageSurperTable - 1) * this.eachPageSurperTable + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperTable = true + + //处理查询数据 + // if(!this.surperTableFilter.surperTSearchText.trim()){ + // this.surperWhere = "" + // } + + //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null + TaosRestful.selectData(this.surperTableName, this.theDB, payload, fields = this.surperTableFilter.fields, + where = this.surperWhere, limit = this.eachPageSurperTable, offset = offsetVal, + desc = this.surperTorder, startTime = startTime, endTime = endTime) + .then(data => { + if (data.res) { + //成功 + if (data.data.length !== 0) { + if (isFirst) { + this.surperTableLabelItems = Object.keys(data.data[0]) + } + this.surperTableLabel = Object.keys(data.data[0]) + this.surperTableFilter.fields = Object.keys(data.data[0]) + this.formatBoolean(data.data) + this.surperTableData = data.data + this.totalSurperTable = data.count + } else { + this.surperTableLabel = [] + this.formatBoolean(data.data) + this.surperTableData = data.data + this.totalSurperTable = data.count + this.$message({ + message: '无数据', + type: 'warning', + duration: 1000 + }); + } + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingSurperTable = false + + }) + }, + selectTData(isFirst, isResetPage = false) { + + //处理时间范围 + let startTime = null + let endTime = null + if (this.tableFilter.dateRange) { + startTime = this.tableFilter.dateRange[0]; + endTime = this.tableFilter.dateRange[1]; + } + + if (isResetPage) { + this.currentPageTable = 1 + } + + let offsetVal = (this.currentPageTable - 1) * this.eachPageTable + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTable = true + + // if(!this.tableFilter.tableSearchText.trim()){ + // this.tableWhere = "" + // } + + //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null + TaosRestful.selectData(this.tableName, this.theDB, payload, fields = this.tableFilter.fields, + where = this.tableWhere, limit = this.eachPageTable, offset = offsetVal, + desc = this.Torder, startTime = startTime, endTime = endTime) + .then(data => { + if (data.res) { + //成功 + if (data.data.length !== 0) { + if (isFirst) { + this.tableLabelItems = Object.keys(data.data[0]) + } + this.tableLabel = Object.keys(data.data[0]) + this.tableFilter.fields = Object.keys(data.data[0]) + this.formatBoolean(data.data) + this.tableData = data.data + this.totalTable = data.count + } else { + this.tableLabel = [] + this.formatBoolean(data.data) + this.tableData = data.data + this.totalTable = data.count + this.$message({ + message: '无数据', + type: 'warning', + duration: 1000 + }); + } + } + this.loadingTable = false + }) + }, + surTableFilter() { + this.selectSurperData(0) + }, + handleClickSurperT(val) { + if (val) { + this.clearSurperTable() + this.surperTableName = val.name + this.selectSurperData(true) + } + }, + handleClickT(val) { + if (val) { + this.clearTable() + this.tableName = val.table_name + this.selectTData(true) + } + }, + paginationSurperChange() { + this.selectSurperData(false) + }, + paginationChange() { + this.selectTData(false) + }, + editSurperT(val) { + console.log(val) + }, + deleteSurperT(val) { + this.$confirm('确认删除超级表' + val + "吗？") + .then(_ => { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + + //TODO没测试过 + TaosRestful.dropTable(val, this.theDB, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 500 + }); + } + this.loadingSurperList = false + this.freshSurperTables() + }) + + }) + }, + editT(val) { + console.log(val) + }, + deleteT(table_name) { + this.$confirm('确认删除表' + table_name + "吗？") + .then(_ => { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + + //TODO没测试过 + TaosRestful.dropTable(table_name, this.theDB, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 500 + }); + } + this.loadingTableList = false + this.freshTables() + }) + }) + }, + sendSQL() { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + TaosRestful.rawSql(this.consoleInput, payload).then(data => { + if (data.res) { + this.consoleResult = data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + }) + }, + closeSuperTdialog() { + this.SuperTdialogText = "" + this.SuperTdialog = false + }, + closeTdialog() { + this.TdialogText = "" + this.Tdialog = false + }, + STChooseAll() { + this.surperTableFilter.fields = this.surperTableLabelItems + }, + STChooseReverse() { + let newFields = this.surperTableLabelItems.filter((item) => { + return this.surperTableFilter ? this.surperTableFilter.fields.indexOf(item) == -1 : false; + }) + this.surperTableFilter.fields = newFields + }, + TChooseAll() { + this.tableFilter.fields = this.tableLabelItems + }, + TChooseReverse() { + let newFields = this.tableLabelItems.filter((item) => { + return this.tableLabelItems.fields ? this.tableLabelItems.fields.indexOf(item) == -1 : false; + }) + this.tableFilter.fields = newFields + } + + } +}) + + diff --git a/renderer/js/taosrestful.js b/renderer/js/taosrestful.js new file mode 100644 index 0000000..9eda859 --- /dev/null +++ b/renderer/js/taosrestful.js @@ -0,0 +1,289 @@ +'use strict' +const axios = require('axios') + +module.exports = class TaosRestful { + constructor(ip = 'localhost', port = '6041', user = 'root', password = "taosdata", timeout = 0) { + this.ip = ip + this.port = port + this.user = user + this.password = password + this.database = 'log' + this.timeout = timeout * 1000 + } + + async sendRequest(sqlStr) { + try { + let res = await axios.post(`http://${this.ip}:${this.port}/rest/sql`, sqlStr, { + auth: { + username: this.user, + password: this.password + }, + timeout: this.timeout + }) + + if (res.data.status == 'succ') { + // console.log(res.data.data) + // console.log(res.data.rows) + // console.log(res.data.head) + let head = res.data.head + let resData = res.data.data.map(item => Object.fromEntries(head.map((a, b) => [a, item[b]]))) + return {'res': true, 'count': res.data.rows, 'data': resData} + } else { + return {'res': false, 'msg': res.data.desc, 'code': res.data.code} + } + } catch (err) { + if (err.response) { + return {'res': false, 'msg': err.response.data.desc, 'code': err.response.data.code} + } else { + return {'res': false, 'msg': 'connect error', 'code': -1} + } + + } + + } + + showDatabases() { + return this.sendRequest('SHOW DATABASES') + } + + testConnect() { + return this.sendRequest('SELECT SERVER_VERSION()').then(a => { + if (a.res === false && a.code === -1) { + return false + } else { + return true + } + } + ) + } + + getVersion() { + return this.sendRequest('SELECT SERVER_VERSION()').then(a => { + if (a.res === false) { + return a.msg + } else { + return a.data[0]['server_version()'] + } + } + ) + } + + //创建新的数据库 + createDatabase(dbName, safe = true, keep = null, update = false, comp = null, replica = null, quorum = null, blocks = null) { + let sqlStr = 'CREATE DATABASE ' + if (safe) { + sqlStr += 'IF NOT EXISTS ' + } + sqlStr += dbName + + if (keep != null) { + sqlStr += ` KEEP ${keep}` + } + if (comp != null) { + sqlStr += ` COMP ${comp}` + } + if (replica != null) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum != null) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks != null) { + sqlStr += ` BLOCKS ${blocks}` + } + if (update) { + sqlStr += ` UPDATE 1` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr) + } + + alterDatabase(dbName, keep = null, comp = null, replica = null, quorum = null, blocks = null) { + let sqlStr = 'ALTER DATABASE ' + sqlStr += dbName + if (keep != null) { + sqlStr += ` KEEP ${keep}` + } + if (comp != null) { + sqlStr += ` COMP ${comp}` + } + if (replica != null) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum != null) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks != null) { + sqlStr += ` BLOCKS ${blocks}` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr) + } + + useDatabase(dbName) { + this.database = dbName + } + + dropDatabase(dbName, safe = true) { + // console.log(`DROP DATABASE ${safe?'IF EXISTS':''} ${dbName}`) + return this.sendRequest(`DROP DATABASE ${safe ? 'IF EXISTS' : ''} ${dbName}`) + } + + showSuperTables(dbName = null, like = null) { + let dbN = dbName ? dbName : this.database + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbN}.STABLES ${likeStr}`) + } + + showTables(dbName = null, like = null) { + let dbN = dbName ? dbName : this.database + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbN}.TABLES ${likeStr}`) + } + + disTable(tableName, dbName = null) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`DESCRIBE ${dbN}.${tableName}`) + } + + dropTable(tableName, dbName = null, safe = false) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbN}.${tableName}`) + } + + insertData(tableName, data, dbName = null) { + let dbN = dbName ? dbName : this.database + let fields = '' + let values = '' + for (const [key, value] of Object.entries(data)) { + fields += key + ',' + values += value + ',' + } + // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` ) + return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`) + } + + timeWhere(primaryKey, where, startTime, endTime) { + where = where || '' + if (where) { + where += startTime ? ` and ${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } else { + where += startTime ? `${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } + return where + } + + countData(tableName, where = '', dbName = null, startTime = null, endTime = null) { + return this.disTable(tableName, dbName).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + return this.countDataIn(tableName, primaryKey, where, dbName, startTime, endTime) + }) + } + + countDataIn(tableName, primaryKey, where = '', dbName = null, startTime = null, endTime = null) { + where = this.timeWhere(primaryKey, where, startTime, endTime) + let dbN = dbName ? dbName : this.database + let sqlStr = 'SELECT ' + let fieldStr = 'count(*)' + sqlStr += fieldStr + ` FROM ${dbN}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr).then(result => { + if (result.res && result.data.length > 0) { + return new Promise((resolve, reject) => { + resolve(result.data[0]['count(*)']) + }) + } else { + return new Promise((resolve, reject) => { + resolve(0) + }) + } + }) + + } + + //查询数据 + selectData(tableName, fields = null, where = '', limit = null, offset = null, desc = null, dbName = null, startTime = null, endTime = null) { + return this.disTable(tableName, dbName).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + + where = this.timeWhere(primaryKey, where, startTime, endTime) + let dbN = dbName ? dbName : this.database + let sqlStr = 'SELECT ' + let fieldStr = '*' + if (fields && fields.length > 0) { + fieldStr = '' + fields.forEach(function (field) { + fieldStr += field + ',' + }); + fieldStr = fieldStr.slice(0, -1) + } + sqlStr += fieldStr + ` FROM ${dbN}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + if (desc === 'DESC') { + sqlStr += ` ORDER BY ${primaryKey} ${desc} ` + } + + if (limit != null) { + sqlStr += ` LIMIT ${limit} ` + } + if (offset != null) { + sqlStr += ` OFFSET ${offset} ` + } + + // console.log(sqlStr) + if (limit != null) { + return this.sendRequest(sqlStr).then(res => { + // console.log(res) + return this.countDataIn(tableName, primaryKey, where, dbName, startTime, endTime).then(count => { + res.count = count + return new Promise((resolve, reject) => { + resolve(res) + }) + }) + }) + } else { + return this.sendRequest(sqlStr) + } + + }) + + + } + + rawSql(sqlStr) { + return this.sendRequest(sqlStr) + } + + rawSqlWithDB(sqlStr, dbName = null) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`USE ${dbN}`).then(a => { + return this.sendRequest(sqlStr) + }) + } +} + diff --git a/renderer/js/taosrestful_.js b/renderer/js/taosrestful_.js new file mode 100644 index 0000000..b4b75f0 --- /dev/null +++ b/renderer/js/taosrestful_.js @@ -0,0 +1,265 @@ +const axios = require('axios') +const { formatResult } = require('./versionAdapter') + +module.exports = { + async sendRequest(sqlStr, payload) { + // console.log(sqlStr) + try { + if (!payload.timeout) { + payload.timeout = 10000; + } + let res = await axios.post(`http://${payload.ip}:${payload.port}/rest/sql`, sqlStr, { + auth: { + username: payload.user, + password: payload.password + }, + timeout: payload.timeout + }) + + res = formatResult(res, sqlStr) + + if (res.data.status === 'succ') { + // console.log(res.data.data) + // console.log(res.data.rows) + // console.log(res.data.head) + let head = res.data.head + let resData = res.data.data.map(item => Object.fromEntries(head.map((a, b) => [a, item[b]]))) + return {'res': true, 'count': res.data.rows, 'data': resData} + } else { + return {'res': false, 'msg': res.data.desc, 'code': res.data.code} + } + } catch (err) { + if (err.response) { + return {'res': false, 'msg': err.response.data.desc, 'code': err.response.data.code} + } else { + return {'res': false, 'msg': '连接错误', 'code': -1} + } + } + + }, + showDatabases(payload) { + return this.sendRequest('SHOW DATABASES', payload) + }, + testConnect(payload) { + return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a => { + return !(a.res === false && a.code === -1); + } + ) + }, + getVersion(payload) { + //获取服务器版本 + return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a => { + return a.res === false ? 'unkown' : a.data[0]['server_version()']; + } + ) + }, + //添加数据库 + createDatabase(dbName, payload, safe = true, keep = null, update = 0, comp = null, + replica = null, quorum = null, blocks = null, version) { + let sqlStr = 'CREATE DATABASE ' + if (safe) { + sqlStr += 'IF NOT EXISTS ' + } + sqlStr += dbName + + if (keep) { + sqlStr += ` KEEP ${keep}` + } + if (comp) { + sqlStr += ` COMP ${comp}` + } + if (replica) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks) { + sqlStr += ` BLOCKS ${blocks}` + } + if (update) { + if (this.compareVersion(version, '2.0.8.0')) { + if (update == 2) { + if (this.compareVersion(version, '2.1.7.0')) { + sqlStr += ` UPDATE ${update}` + } else { + console.log("update参数暂不支持：" + version + "版本") + } + } else { + sqlStr += ` UPDATE ${update}` + } + } else { + console.log("update参数暂不支持：" + version + "版本") + } + } + return this.sendRequest(sqlStr, payload) + }, +// alterDatabase(dbName,keep=null,comp=null,replica=null,quorum=null,blocks=null){ +// let sqlStr = 'ALTER DATABASE ' +// sqlStr += dbName +// if(keep != null){ +// sqlStr += ` KEEP ${keep}` +// } +// if(comp != null){ +// sqlStr += ` COMP ${comp}` +// } +// if(replica != null){ +// sqlStr += ` REPLICA ${replica}` +// } +// if(quorum != null){ +// sqlStr += ` QUORUM ${quorum}` +// } +// if(blocks != null){ +// sqlStr += ` BLOCKS ${blocks}` +// } +// // console.log(sqlStr) +// return this.sendRequest(sqlStr) +// }, +// useDatabase(dbName){ +// this.database = dbName +// }, + dropDatabase(dbName, payload, safe = true) { + return this.sendRequest(`DROP DATABASE ${safe ? 'IF EXISTS' : ''} ${dbName}`, payload) + }, + showSuperTables(dbName, payload, like = null) { + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbName}.STABLES ${likeStr}`, payload) + }, + showTables(dbName, payload, like = null) { + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbName}.TABLES ${likeStr}`, payload) + }, + disTable(tableName, dbName, payload) { + return this.sendRequest(`DESCRIBE ${dbName}.${tableName}`, payload) + }, + dropTable(tableName, dbName, payload, safe = false) { + return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbName}.${tableName}`, payload) + }, + insertData(tableName, data, dbName = null) { + let dbN = dbName ? dbName : this.database + let fields = '' + let values = '' + for (const [key, value] of Object.entries(data)) { + fields += key + ',' + values += value + ',' + } + // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` ) + return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`) + }, + timeWhere(primaryKey, where, startTime, endTime) { + where = where || '' + if (where) { + where += startTime ? ` and ${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } else { + where += startTime ? `${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } + return where + }, + //查询数据 + selectData(tableName, dbName, payload, fields = null, where = null, limit = null, + offset = null, desc = null, startTime = null, endTime = null) { + //首先查询一次，获取表的整体情况 + return this.disTable(tableName, dbName, payload).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + //获取第一项，时间戳 + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + + //组装where子句 //TODO + where = this.timeWhere(primaryKey, where, startTime, endTime) + let sqlStr = 'SELECT ' + let fieldStr = '*' + if (fields && fields.length > 0) { + fieldStr = '' + fields.forEach(function (field) { + fieldStr += field + ',' + }); + fieldStr = fieldStr.slice(0, -1) + } + sqlStr += fieldStr + ` FROM ${dbName}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + if (desc === 'DESC') { + sqlStr += ` ORDER BY ${primaryKey} ${desc} ` + } + + if (limit != null) { + sqlStr += ` LIMIT ${limit} ` + } + if (offset != null) { + sqlStr += ` OFFSET ${offset} ` + } + + //把总数数出来 + if (limit != null) { + return this.sendRequest(sqlStr, payload).then(res => { + return this.countDataIn(tableName, dbName, primaryKey, payload, where).then(count => { + res.count = count + return new Promise((resolve, reject) => { + resolve(res) + }) + }) + }) + } else { + return this.sendRequest(sqlStr, payload) + } + + }) + + }, + countDataIn(tableName, dbName, primaryKey, payload, where = '', startTime = null, endTime = null) { + where = this.timeWhere(primaryKey, where, startTime, endTime) + let sqlStr = 'SELECT ' + let fieldStr = 'count(*)' + sqlStr += fieldStr + ` FROM ${dbName}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr, payload).then(result => { + if (result.res && result.data.length > 0) { + return new Promise((resolve, reject) => { + resolve(result.data[0]['count(*)']) + }) + } else { + return new Promise((resolve, reject) => { + resolve(0) + }) + } + }) + }, + rawSql(sqlStr, payload) { + return this.sendRequest(sqlStr, payload) + }, + compareVersion(serverVersion, targetVersion) { + if (serverVersion == targetVersion) { + return true; + } + let serverArray = serverVersion.split("."); + let targetArray = targetVersion.split("."); + let length = Math.min(serverArray.length, targetArray.length); + for (let i = 0; i < length; i++) { + if (serverArray[i] > targetArray[i]) { + return true; + } else if (serverArray[i] < targetArray[i]) { + return false; + } + } + return false; + } +} + diff --git a/renderer/js/versionAdapter.js b/renderer/js/versionAdapter.js new file mode 100644 index 0000000..59a3418 --- /dev/null +++ b/renderer/js/versionAdapter.js @@ -0,0 +1,26 @@ +module.exports = { + formatResult(res, sql) { + if (res.data.status !== undefined) { + // Version 2.x + return res + } + + if (res.data.code === 0) { + res.data.status = 'succ' + res.data.head = res.data.column_meta.map(item => item[0]) + } else { + res.data.status = 'error' + } + + if ( + /show /i.test(sql) && + /.stables/i.test(sql) && + res.data.head.length === 1 && + res.data.head[0] === 'stable_name' + ) { + res.data.head[0] = 'name' + } + + return res + } +} diff --git a/renderer/js/vue-clipboard2/vue-clipboard.min.js b/renderer/js/vue-clipboard2/vue-clipboard.min.js new file mode 100644 index 0000000..d7d417f --- /dev/null +++ b/renderer/js/vue-clipboard2/vue-clipboard.min.js @@ -0,0 +1 @@ +(function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i Object.fromEntries(head.map((a,b)=>[a,item[b]])))
- return {'res':true,'count':res.data.rows,'data':resData}
- }else{
- return {'res':false,'msg':res.data.desc,'code':res.data.code}
- }
- } catch (err) {
- if (err.response){
- return {'res':false,'msg':err.response.data.desc,'code':err.response.data.code}
- }else{
- return {'res':false,'msg':'connect error','code':-1}
- }
-
- }
-
- }
- showDatabases(){
- return this.sendRequest('SHOW DATABASES')
- }
- testConnect(){
- return this.sendRequest('SELECT SERVER_VERSION()').then(a =>
- {
- if (a.res === false && a.code === -1){
- return false
- }else{
- return true
- }
- }
- )
- }
-
- getVersion(){
- return this.sendRequest('SELECT SERVER_VERSION()').then(a =>
- {
- if (a.res === false){
- return a.msg
- }else{
- return a.data[0]['server_version()']
- }
- }
- )
- }
- //创建新的数据库
- createDatabase(dbName,safe=true,keep= null,update=false,comp=null,replica=null,quorum=null,blocks=null){
- let sqlStr = 'CREATE DATABASE '
- if(safe){
- sqlStr += 'IF NOT EXISTS '
- }
- sqlStr += dbName
-
- if(keep != null){
- sqlStr += ` KEEP ${keep}`
- }
- if(comp != null){
- sqlStr += ` COMP ${comp}`
- }
- if(replica != null) {
- sqlStr += ` REPLICA ${replica}`
- }
- if(quorum != null){
- sqlStr += ` QUORUM ${quorum}`
- }
- if(blocks != null){
- sqlStr += ` BLOCKS ${blocks}`
- }
- if(update){
- sqlStr += ` UPDATE 1`
- }
- // console.log(sqlStr)
- return this.sendRequest(sqlStr)
- }
-
- alterDatabase(dbName,keep=null,comp=null,replica=null,quorum=null,blocks=null){
- let sqlStr = 'ALTER DATABASE '
- sqlStr += dbName
- if(keep != null){
- sqlStr += ` KEEP ${keep}`
- }
- if(comp != null){
- sqlStr += ` COMP ${comp}`
- }
- if(replica != null){
- sqlStr += ` REPLICA ${replica}`
- }
- if(quorum != null){
- sqlStr += ` QUORUM ${quorum}`
- }
- if(blocks != null){
- sqlStr += ` BLOCKS ${blocks}`
- }
- // console.log(sqlStr)
- return this.sendRequest(sqlStr)
- }
-
- useDatabase(dbName){
- this.database = dbName
- }
- dropDatabase(dbName,safe=true){
- // console.log(`DROP DATABASE ${safe?'IF EXISTS':''} ${dbName}`)
- return this.sendRequest(`DROP DATABASE ${safe?'IF EXISTS':''} ${dbName}`)
- }
- showSuperTables(dbName=null,like=null){
- let dbN = dbName ? dbName : this.database
- let likeStr = like?` LIKE '%${like}%'`:''
- return this.sendRequest(`SHOW ${dbN}.STABLES ${likeStr}`)
- }
- showTables(dbName=null,like=null){
- let dbN = dbName ? dbName : this.database
- let likeStr = like?` LIKE '%${like}%'`:''
- return this.sendRequest(`SHOW ${dbN}.TABLES ${likeStr}`)
- }
- disTable(tableName,dbName=null){
- let dbN = dbName ? dbName : this.database
- return this.sendRequest(`DESCRIBE ${dbN}.${tableName}`)
- }
- dropTable(tableName,dbName=null,safe=false){
- let dbN = dbName ? dbName : this.database
- return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbN}.${tableName}`)
- }
-
- insertData(tableName,data,dbName=null){
- let dbN = dbName ? dbName : this.database
- let fields = ''
- let values = ''
- for (const [key, value] of Object.entries(data)) {
- fields += key + ','
- values += value + ','
- }
- // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` )
- return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`)
- }
- timeWhere(primaryKey,where,startTime,endTime){
- where = where || ''
- if(where){
- where += startTime? ` and ${primaryKey} > '${startTime}' ` : ''
- if(where){
- where += endTime? ` and ${primaryKey} < '${endTime}' ` : ''
- }else{
- where += endTime? `${primaryKey} < '${endTime}' ` : ''
- }
- }else{
- where += startTime? `${primaryKey} > '${startTime}' ` : ''
- if(where){
- where += endTime? ` and ${primaryKey} < '${endTime}' ` : ''
- }else{
- where += endTime? `${primaryKey} < '${endTime}' ` : ''
- }
- }
- return where
- }
- countData(tableName,where='',dbName=null,startTime=null,endTime=null){
- return this.disTable(tableName,dbName).then(res=>{
- let primaryKey ='ts'
- if(res.res && res.data.length>0){
- primaryKey = res.data[0].Field
- }else{
- return {'res':false,'msg':'distable error','code':99}
- }
- return this.countDataIn(tableName,primaryKey,where,dbName,startTime,endTime)
- })
- }
- countDataIn(tableName,primaryKey,where='',dbName=null,startTime=null,endTime=null){
- where = this.timeWhere(primaryKey,where,startTime,endTime)
- let dbN = dbName ? dbName : this.database
- let sqlStr = 'SELECT '
- let fieldStr= 'count(*)'
- sqlStr += fieldStr + ` FROM ${dbN}.${tableName} `
- if(where){
- sqlStr +=` WHERE ${where} `
- }
- // console.log(sqlStr)
- return this.sendRequest(sqlStr).then(result=>{
- if (result.res && result.data.length >0){
- return new Promise((resolve, reject)=>{resolve(result.data[0]['count(*)'])})
- }else{
- return new Promise((resolve, reject)=>{resolve(0)})
- }
- })
-
- }
-
- //查询数据
- selectData(tableName,fields=null,where='',limit =null,offset = null,desc =null,dbName=null,startTime=null,endTime=null){
- return this.disTable(tableName,dbName).then(res=>{
- let primaryKey ='ts'
- if(res.res && res.data.length>0){
- primaryKey = res.data[0].Field
- }else{
- return {'res':false,'msg':'distable error','code':99}
- }
-
- where = this.timeWhere(primaryKey,where,startTime,endTime)
- let dbN = dbName ? dbName : this.database
- let sqlStr = 'SELECT '
- let fieldStr= '*'
- if(fields && fields.length>0){
- fieldStr= ''
- fields.forEach(function(field){
- fieldStr += field + ','
- });
- fieldStr = fieldStr.slice(0,-1)
- }
- sqlStr += fieldStr + ` FROM ${dbN}.${tableName} `
- if(where){
- sqlStr +=` WHERE ${where} `
- }
- if(desc === 'DESC'){
- sqlStr +=` ORDER BY ${primaryKey} ${desc} `
- }
-
- if(limit != null){
- sqlStr +=` LIMIT ${limit} `
- }
- if(offset != null){
- sqlStr +=` OFFSET ${offset} `
- }
-
- // console.log(sqlStr)
- if(limit != null){
- return this.sendRequest(sqlStr).then(res=>{
- // console.log(res)
- return this.countDataIn(tableName,primaryKey,where,dbName,startTime,endTime).then(count=>{
- res.count=count
- return new Promise((resolve, reject)=>{resolve(res)})
- })
- })
- }else{
- return this.sendRequest(sqlStr)
- }
-
- })
-
-
- }
- rawSql(sqlStr){
- return this.sendRequest(sqlStr)
- }
- rawSqlWithDB(sqlStr,dbName=null){
- let dbN = dbName ? dbName : this.database
- return this.sendRequest(`USE ${dbN}`).then(a =>{
- return this.sendRequest(sqlStr)
- })
- }
-}
-
diff --git a/renderer/taosrestful_.js b/renderer/taosrestful_.js
deleted file mode 100644
index c0faa42..0000000
--- a/renderer/taosrestful_.js
+++ /dev/null
@@ -1,240 +0,0 @@
-const axios = require('axios')
-
-module.exports = {
- async sendRequest(sqlStr, payload){
- // console.log(sqlStr)
- try {
- let res = await axios.post(`http://${payload.ip}:${payload.port}/rest/sql`, sqlStr, {
- auth: {
- username: payload.user,
- password: payload.password
- },
- timeout: payload.timeout
- })
- if (res.data.status == 'succ'){
- // console.log(res.data.data)
- // console.log(res.data.rows)
- // console.log(res.data.head)
- let head = res.data.head
- let resData = res.data.data.map(item => Object.fromEntries(head.map((a,b)=>[a,item[b]])))
- return {'res':true,'count':res.data.rows,'data':resData}
- }else{
- return {'res':false,'msg':res.data.desc,'code':res.data.code}
- }
- } catch (err) {
- if (err.response){
- return {'res':false,'msg':err.response.data.desc,'code':err.response.data.code}
- }else{
- return {'res':false,'msg':'连接错误','code':-1}
- }
-
- }
-
- },
- showDatabases(payload){
- return this.sendRequest('SHOW DATABASES', payload)
- },
- testConnect(payload){
- return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a =>
- {
- if (a.res === false && a.code === -1){
- return false
- }else{
- return true
- }
- }
- )
- },
- getVersion(payload){
- //获取服务器版本
- return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a =>
- {
- if (a.res === false){
- return 'unkown'
- }else{
- return a.data[0]['server_version()']
- }
- }
- )
- },
- //添加数据库
- createDatabase(dbName, payload,safe=true,keep= null,update=false,comp=null,replica=null,quorum=null,blocks=null){
- let sqlStr = 'CREATE DATABASE '
- if(safe){
- sqlStr += 'IF NOT EXISTS '
- }
- sqlStr += dbName
-
- if(keep){
- sqlStr += ` KEEP ${keep}`
- }
- if(comp){
- sqlStr += ` COMP ${comp}`
- }
- if(replica) {
- sqlStr += ` REPLICA ${replica}`
- }
- if(quorum){
- sqlStr += ` QUORUM ${quorum}`
- }
- if(blocks){
- sqlStr += ` BLOCKS ${blocks}`
- }
- if(update){
- sqlStr += ` UPDATE 1`
- }
- // console.log(sqlStr)
- return this.sendRequest(sqlStr, payload)
- },
-// alterDatabase(dbName,keep=null,comp=null,replica=null,quorum=null,blocks=null){
-// let sqlStr = 'ALTER DATABASE '
-// sqlStr += dbName
-// if(keep != null){
-// sqlStr += ` KEEP ${keep}`
-// }
-// if(comp != null){
-// sqlStr += ` COMP ${comp}`
-// }
-// if(replica != null){
-// sqlStr += ` REPLICA ${replica}`
-// }
-// if(quorum != null){
-// sqlStr += ` QUORUM ${quorum}`
-// }
-// if(blocks != null){
-// sqlStr += ` BLOCKS ${blocks}`
-// }
-// // console.log(sqlStr)
-// return this.sendRequest(sqlStr)
-// },
-// useDatabase(dbName){
-// this.database = dbName
-// },
- dropDatabase(dbName, payload,safe=true){
- return this.sendRequest(`DROP DATABASE ${safe?'IF EXISTS':''} ${dbName}`, payload)
- },
- showSuperTables(dbName, payload,like=null){
- let likeStr = like?` LIKE '%${like}%'`:''
- return this.sendRequest(`SHOW ${dbName}.STABLES ${likeStr}`, payload)
- },
- showTables(dbName, payload,like=null){
- let likeStr = like?` LIKE '%${like}%'`:''
- return this.sendRequest(`SHOW ${dbName}.TABLES ${likeStr}`, payload)
- },
- disTable(tableName,dbName, payload){
- return this.sendRequest(`DESCRIBE ${dbName}.${tableName}`, payload )
- },
- dropTable(tableName,dbName, payload,safe=false){
- return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbName}.${tableName}`, payload )
- },
- insertData(tableName,data,dbName=null){
- let dbN = dbName ? dbName : this.database
- let fields = ''
- let values = ''
- for (const [key, value] of Object.entries(data)) {
- fields += key + ','
- values += value + ','
- }
- // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` )
- return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`)
- },
- timeWhere(primaryKey,where,startTime,endTime){
- where = where || ''
- if(where){
- where += startTime? ` and ${primaryKey} > '${startTime}' ` : ''
- if(where){
- where += endTime? ` and ${primaryKey} < '${endTime}' ` : ''
- }else{
- where += endTime? `${primaryKey} < '${endTime}' ` : ''
- }
- }else{
- where += startTime? `${primaryKey} > '${startTime}' ` : ''
- if(where){
- where += endTime? ` and ${primaryKey} < '${endTime}' ` : ''
- }else{
- where += endTime? `${primaryKey} < '${endTime}' ` : ''
- }
- }
- return where
- },
- //查询数据
- selectData(tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null){
- //首先查询一次，获取表的整体情况
- return this.disTable(tableName,dbName, payload).then(res=>{
- let primaryKey ='ts'
- if(res.res && res.data.length>0){
- //获取第一项，时间戳
- primaryKey = res.data[0].Field
- }else{
- return {'res':false,'msg':'distable error','code':99}
- }
-
- //组装where子句 //TODO
- where = this.timeWhere(primaryKey,where,startTime,endTime)
- let sqlStr = 'SELECT '
- let fieldStr= '*'
- if(fields && fields.length>0){
- fieldStr= ''
- fields.forEach(function(field){
- fieldStr += field + ','
- });
- fieldStr = fieldStr.slice(0,-1)
- }
- sqlStr += fieldStr + ` FROM ${dbName}.${tableName} `
- if(where){
- sqlStr +=` WHERE ${where} `
- }
- if(desc === 'DESC'){
- sqlStr +=` ORDER BY ${primaryKey} ${desc} `
- }
-
- if(limit != null){
- sqlStr +=` LIMIT ${limit} `
- }
- if(offset != null){
- sqlStr +=` OFFSET ${offset} `
- }
-
- //把总数数出来
- if(limit != null){
- return this.sendRequest(sqlStr, payload).then(res=>{
- return this.countDataIn(tableName,dbName,primaryKey, payload ,where).then(count=>{
- res.count=count
- return new Promise((resolve, reject)=>{resolve(res)})
- })
- })
- }else{
- return this.sendRequest(sqlStr, payload)
- }
-
- })
-
- },
- countDataIn(tableName, dbName,primaryKey, payload, where='',startTime=null,endTime=null){
- where = this.timeWhere(primaryKey,where,startTime,endTime)
- let sqlStr = 'SELECT '
- let fieldStr= 'count(*)'
- sqlStr += fieldStr + ` FROM ${dbName}.${tableName} `
- if(where){
- sqlStr +=` WHERE ${where} `
- }
- // console.log(sqlStr)
- return this.sendRequest(sqlStr,payload).then(result=>{
- if (result.res && result.data.length >0){
- return new Promise((resolve, reject)=>{resolve(result.data[0]['count(*)'])})
- }else{
- return new Promise((resolve, reject)=>{resolve(0)})
- }
- })
- },
- rawSql(sqlStr,payload){
- return this.sendRequest(sqlStr,payload)
- },
- rawSqlWithDB(sqlStr,dbName,payload){
- // let dbN = dbName ? dbName : this.database
- return this.sendRequest(`USE ${dbName}`,payload).then(a =>{
- return this.sendRequest(sqlStr,payload)
- })
- }
-}
-
-
-
+
-
-
+
+
+
+
+
+
+
+
+
+ 全选
+ 反选
+
+
+
+
+ {{ label }}
+
+
+
+
+
+
+
+
+ 10
+ 20
+ 30
+ 50
+
+
+
+
+
-
-
-
- 筛选条件
-
-
- 数据刷新
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 表名
-
-
+
+
diff --git a/renderer/index.js b/renderer/index.js
deleted file mode 100644
index 43a9f3a..0000000
--- a/renderer/index.js
+++ /dev/null
@@ -1,961 +0,0 @@
-const TaosRestful = require('./taosrestful_.js')
-const storage = require('./localDataStore.js')
-const { TouchBarScrubber } = require('electron')
-
-new Vue({
- el: '#app',
- mounted: function () {
- let links = storage.getLinks()
- for(let i = 0,len=links.length; i < len; i++) {
- let payload = {
- ip:links[i].host,
- port:links[i].port,
- user:links[i].user,
- password:links[i].password
- }
- TaosRestful.getVersion(payload).then(data => {
- links[i].version = data
- this.$data.links =links
- })
- }
-
- },
- data: function() {
- return {
- dbInfo:'',
- consoleResult:'',
- loadingLinks: false,
- drawer: true,
- addLinkDialog: false,
- linkForm: {
- name:"",
- host:"",
- port:"",
- user:"",
- password:"",
- },
- activeTab:"1",
-
- surperTableFilterCopy:{},
-
- surperTableFilter:{
- fields:[],
- surperDateRange:[],
- surperTSearchText: "",
- surperTSearchColumn: "",
- },
-
- tableFilterCopy:{},
- tableFilter:{
- fields:[],
- dateRange:[],
- tableSearchText:"",
- tableSearchColumn:"",
- },
- surperWhere:"",
- tableWhere:"",
-
- tableFilterDialog:false,
- surperTableFilterDialog:false,
-
- surperTables: [], //超级表list
- surperTableData: [],
- surperTableName: "",
- totalSurperTable: 0,
- surperTableLabelItems: [],
- surperTableLabel: [],
- loadingSurperList: false,
- loadingSurperTable: false,
-
- tables: [], //表list
- tableData: [],
- tableName: "",
- totalTable: 0,
- tableLabelItems: [],
- tableLabel: [],
- loadingTableList: false,
- loadingTable: false,
-
- eachPageSurperTable:10,
- currentPageSurperTable:1,
- eachPageTable:10,
- currentPageTable:1,
-
- addDBDialogLinkKey:0,
- addDBDialog:false,
- addDBname:"",
- addDBcomp:"",
- addDBreplica:"",
- addDBkeep:"",
- addDBupdate:false,
- addDBquorum:"",
- addDBblocks:"",
-
- searchIcon: true,
- freshIcon: true,
- links:[],
- theLink:{}, //当前连接
- theDB: "", //当前数据库
-
- SuperTdialog: false,
- SuperTdialogText: "",
- Tdialog: false,
- TdialogText: "",
-
- surperTorder:"ASC",
- Torder:"ASC",
- consoleInput: "",
- marks: {
- 0: '0',
- 365: '365',
- 36500: '36500'
- }
- }
- },
- methods: {
- beforeClosedrawer(){
- if(this.theDB){
- this.drawer = false
- } else {
- this.$message({
- message: '请选择数据库',
- type: 'warning',
- duration:1000
- });
- }
- },
- cancelAddLink() {
- this.addLinkDialog = false
- //清空表单
- this.linkForm={
- name:"",
- host:"",
- port:"",
- user:"",
- password:""
- }
- },
- confirmAddLink(event) {
- //新建连接，先连接，如果成功，将payload+name记入本地
- //var tr = new TaosRestful("121.36.56.117","6041","root","msl110918")
- let payload = {
- ip:this.linkForm.host,
- port:this.linkForm.port,
- user:this.linkForm.user,
- password:this.linkForm.password
- }
- TaosRestful.showDatabases(payload).then(data =>{
- //处理返回的数据库数据
- if(data.res){
-
- TaosRestful.getVersion(payload).then(_data => {
- //连接成功，保存到本地
- storage.AddALink({
- name: this.linkForm.name,
- host: this.linkForm.host,
- port: this.linkForm.port,
- user: this.linkForm.user,
- password: this.linkForm.password,
- version: _data
- })
- //关闭新建连接的弹窗
- this.addLinkDialog = false
- //清空表单
- this.linkForm={
- name:"",
- host:"",
- port:"",
- user:"",
- password:"",
- }
-
- //更新连接列表
- this.links = storage.getLinks()
- })
-
- } else {
- //连接失败
- this.$message({
- message: '连接失败',
- type: 'error',
- duration:1000
- });
- }
-
- }
- )
-
- },
- deleteLink(key, linkName){
- this.$confirm('确认删除连接' + linkName + "吗？")
- .then(_ => {
- storage.deleteALink(key)
- this.links = storage.getLinks()
- this.$message({
- message: '删除成功',
- type: 'success',
- duration:500
- });
- })
- .catch(_ => {
- this.$message({
- message: '操作已取消',
- type: 'warning',
- duration:500
- });
- });
- },
- freshDB(key){
- let theLink = this.links[key]
- let payload = {
- ip:theLink.host,
- port:theLink.port,
- user:theLink.user,
- password:theLink.password
- }
- this.loadingLinks = true
- TaosRestful.showDatabases(payload).then(data =>{
- this.loadingLinks = false
- if(data.res){
- this.$message({
- message: '刷新成功',
- type: 'success',
- duration:1000
- });
- this.links[key].dbs = data.data
- //TODO展开菜单
-
- } else {
- //连接失败，1.提示 2.删除当前连接 3.重新连接
- //1
- this.$message({
- message: data.msg,
- type: 'error',
- duration:1000
- });
- //2
- storage.deleteALink(key)
- this.links = storage.getLinks()
- //3
- this.$message({
- message: '尝试重新连接',
- type: 'warning',
- duration:1000
- });
- this.linkForm = {
- name: theLink.name,
- host: theLink.host,
- port: theLink.port,
- user: theLink.user,
- password: theLink.password,
- }
- this.addLinkDialog = true
- }
- })
- },
- addDB(key){
- this.addDBDialogLinkKey = key
- this.addDBDialog = true
-
- this.addDBname = ""
- this.addDBcomp = ""
- this.addDBreplica = ""
- this.addDBkeep = ""
- this.addDBupdate = false
- this.addDBquorum = ""
- this.addDBblocks = ""
- },
- postaddDB(){
- let key = this.addDBDialogLinkKey
- let theLink = this.links[key]
- let payload = {
- ip:theLink.host,
- port:theLink.port,
- user:theLink.user,
- password:theLink.password
- }
- if(this.addDBname){
- if(this.addDBreplica && this.addDBquorum){
- if(this.addDBreplica < this.addDBquorum){
- this.$message({
- message: 'replica应大于等于quorum',
- type: 'error',
- duration:1000
- });
- return
- }
- }
- TaosRestful.createDatabase(this.addDBname, payload,safe=true,keep= this.addDBkeep,update=this.addDBupdate,comp=this.addDBcomp, replica=this.addDBreplica,quorum=this.addDBquorum,blocks=this.addDBblocks).then(data => {
- if(data.res){
- //新增成功
- this.$message({
- message: '添加成功',
- type: 'success',
- duration:1000
- });
- this.freshDB(key)
- this.addDBDialog = false
- }else{
- //添加失败
- this.$message({
- message: data.msg,
- type: 'error',
- duration:1000
- });
- }
- })
- } else{
- this.$message({
- message: '请填写内容',
- type: 'warning',
- duration:1000
- });
- }
- },
- deleteDB(link, dbName, key){
- this.$confirm('确认删除数据库' + dbName + "吗？")
- .then(_ => {
- let payload = {
- ip:link.host,
- port:link.port,
- user:link.user,
- password:link.password
- }
- this.loadingLinks = true
-
- TaosRestful.dropDatabase(dbName, payload).then(data => {
-
- if(data.res){
- //成功
- this.$message({
- message: '删除成功',
- type: 'success',
- duration:1000
- });
- } else {
- this.$message({
- message: data.msg,
- type: 'error',
- duration:1000
- });
- }
- this.loadingLinks = false
- this.freshDB(key)
- })
- })
- .catch(_ => {
- this.$message({
- message: '操作已取消',
- type: 'warning',
- duration:1000
- });
- });
- },
- makeDbInfo(dbs,dbName){
- console.log(dbs)
- let info = '无法获取数据库信息'
- dbs.forEach(item => {
- if(item['name'] == dbName){
- info = `数据库名: ${dbName}
-
- {{ scope.row.table_name }}
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+ 时间范围:
+
+
+
+
+
+ 筛选条件
+
+
+
+ 数据刷新
+
+
+
+
+
+
+
+
+
+
+
+
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
+
+
+
+
+
+
+
-
-
-
-
+
+
+
+
+
+
+
+
+ 普通表名
+
+ {{ scope.row.table_name }}
+
+
+
+
+
+
+
+
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ scope.row.table_name }}
+
+
+
+
+
+
+
- {{ scope.row.table_name }}
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 全选
- 反选
-
-
-
-
- {{label}}
-
-
-
-
-
-
-
-
- 10
- 15
- 20
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-
-
-
-
-
- 
- 切换
+
+
+
+
+ 切换
+
-
-
+
-
-
-
+
+
+
+
+
+
+
+ 全选
+ 反选
+
+
+
+
+ {{ label }}
+
+
+
+
+
+
+
+
+
+ 10
+ 20
+ 30
+ 50
+
+
+
+
+
+
+
-
-
-
-
- 时间范围:
-
-
-
+
+ 时间范围:
+
+
+
+
+ 筛选条件
+
+
+
+ 数据刷新
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
+
+
+
+
+
+
+
+
+
+ SQL:
+ 执行
- -->
-
- 筛选条件
-
-
- 数据刷新
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-
+
+
+ 复制
+
+ {{ JSON.stringify(consoleResult, null, 4) }}
+
-
- SQL:
-
-
-
-
-
- {{consoleResult}}
-
- 切换
+ 切换
+ 当前连接:
- {{theLink.name}}
- 主机:
- {{theLink.host}}
- 端口:
- {{theLink.port}}
- 用户名:
- {{theLink.user}}
- 数据库:
- {{theDB}}
+ 当前连接:
+ {{ theLink.name }}
+ 主机:
+ {{ theLink.host }}
+ 端口:
+ {{ theLink.port }}
+ 用户名:
+ {{ theLink.user }}
+ 数据库:
+ {{ theDB }}
` - info += `创建时间: ${item['created_time']}
` - info += `可更新: ${item['update'] == 0?'否':'是'}
` - info += `cache(MB): ${item['cache(MB)']}
` - info += `cachelast: ${item['cachelast']}
` - info += `comp: ${item['comp']}
` - info += `days: ${item['days']}
` - info += `fsync: ${item['fsync']}
` - info += `keep0,keep1,keep(D): ${item['keep0,keep1,keep(D)']}
` - info += `maxrows: ${item['maxrows']}
` - info += `minrows: ${item['minrows']}
` - info += `ntables: ${item['ntables']}
` - info += `quorum: ${item['quorum']}
` - info += `replica: ${item['replica']}
` - info += `status: ${item['status']}
` - info += `vgroups: ${item['vgroups']}
` - info += `wallevel: ${item['wallevel']}
` - info += `precision: ${item['precision']}
` - } - }) - return info - }, - alartDB(link,dbName){ - //切换数据库前先清空表 - this.dbInfo=this.makeDbInfo(link.dbs,dbName) - this.surperTables = [] - this.clearSurperTable() - this.tables = [] - this.clearTable() - - //记录进入的数据库 - this.theLink = link - this.theDB = dbName - - //更新超级表页 - this.drawer = false - this.activeTab = "1" - this.freshSurperTables() - }, - searchSurperTList(){ - this.SuperTdialog = false - this.surperTables = [] - this.clearSurperTable() - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - TaosRestful.showSuperTables(this.theDB, payload, like=this.SuperTdialogText).then(data =>{ - if(data.res){ - //拉取超级表成功 - this.$message({ - message: '查找成功', - type: 'success', - duration:1000 - }); - this.surperTables = data.data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - this.freshSurperTables() - } - this.SuperTdialogText = "" - this.loadingSurperList = false - }) - - }, - freshSurperTList(){ - this.surperTables = [] - this.clearSurperTable() - this.freshSurperTables() - }, - searchTList(){ - this.Tdialog = false - this.tables = [] - this.clearTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - TaosRestful.showTables(this.theDB, payload, like=this.TdialogText).then(data =>{ - if(data.res){ - //拉取表成功 - this.$message({ - message: '查找成功', - type: 'success', - duration:1000 - }); - this.tables = data.data - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - this.freshTables() - - } - this.TdialogText = "" - this.loadingTableList = false - }) - }, - freshTList(){ - this.tables = [] - this.clearTable() - this.freshTables() - }, - clearSurperTable(){ - this.surperTableName = "" - this.totalSurperTable = 0 - this.surperTableData = [] - this.surperTableLabel = [] - this.surperTableFilter={ - fields:[], - surperDateRange:[], - surperTSearchText: "", - surperTSearchColumn: "", - } - }, - clearTable(){ - this.tableName = "" - this.totalTable = 0 - this.tableData = [] - this.tableLabel = [] - this.tableFilter={ - fields:[], - dateRange:[], - tableSearchText:"", - tableSearchColumn:"", - } - }, - freshSurperTables(){ - //清理超级表列表 - this.surperTables = [] - //清理选中的超级表和具体数据 - this.clearSurperTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - TaosRestful.showSuperTables(this.theDB, payload).then(data =>{ - if(data.res){ - //拉取超级表成功 - this.$message({ - message: '刷新成功', - type: 'success', - duration:1000 - }); - this.surperTables = data.data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingSurperList = false - }) - }, - freshTables(){ - //清理表列表 - this.tables = [] - //清理选中的表和具体数据 - this.clearTable() - - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - TaosRestful.showTables(this.theDB, payload).then(data =>{ - if(data.res){ - //拉取表成功 - this.$message({ - message: '刷新成功', - type: 'success', - duration:1000 - }); - this.tables = data.data - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingTableList = false - }) - }, - handleSwichTab(tab) { - switch(tab.name) { - case "1": - //超级表 - this.freshSurperTables() - break; - case "2": - //表 - this.freshTables() - break; - case "3": - //控制台 - break; - case "4": - //数据库属性 - break; - } - }, - openSurperTableFilterD(){ - this.surperTableFilterDialog = true - this.surperTableFilterCopy = JSON.parse(JSON.stringify(this.surperTableFilter)) - }, - concelSurperTableFilter(){ - this.$message({ - message: '取消操作', - type: 'warning', - duration:1000 - }); - this.surperTableFilterDialog = false - this.surperTableFilter = this.surperTableFilterCopy - }, - postSurperTableFilter(){ - this.surperTableFilterDialog = false - this.selectSurperData(false) - }, - openTableFilterD(){ - this.tableFilterDialog = true - this.tableFilterCopy = JSON.parse(JSON.stringify(this.tableFilter)) - }, - concelTableFilter(){ - this.$message({ - message: '取消操作', - type: 'warning', - duration:1000 - }); - this.tableFilterDialog = false - this.tableFilter = this.tableFilterCopy - }, - postTableFilter(){ - this.tableFilterDialog = false - this.selectTData(false) - }, - searchSurperText(){ - if(this.surperTableFilter.surperTSearchColumn && this.surperTableFilter.surperTSearchText.trim()){ - // this.surperWhere = this.surperTSearchColumn + " > " + this.surperTSearchText.trim()+"%" - // this.clearSurperTable() - let surperTSearchText = this.surperTableFilter.surperTSearchText.trim() - if(!isNaN(surperTSearchText)){ - this.surperWhere =this.surperTableFilter.surperTSearchColumn + " = " + surperTSearchText - } else { - this.surperWhere =this.surperTableFilter.surperTSearchColumn + " = '" + surperTSearchText +"'" - } - - this.selectSurperData(false) - } else { - this.surperWhere = "" - this.$message({ - message: '请填写正确', - type: 'warning', - duration:1000 - }); - this.selectSurperData(false) - } - }, - searchTableText(){ - if(this.tableFilter.tableSearchColumn && this.tableFilter.tableSearchText.trim()){ - - let tableSearchText = this.tableFilter.tableSearchText.trim() - if(!isNaN(tableSearchText)){ - this.tableWhere =this.tableFilter.tableSearchColumn + " = " + tableSearchText - } else { - this.tableWhere =this.tableFilter.tableSearchColumn + " = '" + tableSearchText +"'" - } - - this.selectTData(false) - } else { - this.tableWhere = "" - this.$message({ - message: '请填写正确', - type: 'warning', - duration:1000 - }); - this.selectTData(false) - } - }, - selectSurperData(isFirst, isResetPage){ - - //处理时间范围 - let startTime = null - let endTime = null - if(this.surperTableFilter.surperDateRange){ - startTime = this.surperTableFilter.surperDateRange[0]; - endTime = this.surperTableFilter.surperDateRange[1]; - } - - //是否需要重置分页 - if(isResetPage){ - this.currentPageSurperTable = 1 - } - - let offsetVal = (this.currentPageSurperTable-1)*this.eachPageSurperTable - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperTable = true - - //处理查询数据 - // if(!this.surperTableFilter.surperTSearchText.trim()){ - // this.surperWhere = "" - // } - - //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null - TaosRestful.selectData(this.surperTableName, this.theDB, payload, fields=this.surperTableFilter.fields, where=this.surperWhere - , limit=this.eachPageSurperTable, offset=offsetVal, desc=this.surperTorder, startTime=startTime, endTime=endTime) - .then(data =>{ - if(data.res){ - //成功 - if(data.data.length != 0){ - //有数据 - this.$message({ - message: '获取成功', - type: 'success', - duration:1000 - }); - if(isFirst){ - this.surperTableLabelItems = Object.keys(data.data[0]) - } - this.surperTableLabel = Object.keys(data.data[0]) - this.surperTableFilter.fields = Object.keys(data.data[0]) - this.surperTableData = data.data - this.totalSurperTable = data.count - } else { - this.surperTableLabel = [] - this.surperTableData = data.data - this.totalSurperTable = data.count - this.$message({ - message: '无数据', - type: 'warning', - duration:1000 - }); - } - }else{ - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - this.loadingSurperTable = false - - }) - }, - selectTData(isFirst, isResetPage=false){ - - //处理时间范围 - let startTime = null - let endTime = null - if(this.tableFilter.dateRange){ - startTime = this.tableFilter.dateRange[0]; - endTime = this.tableFilter.dateRange[1]; - } - - if(isResetPage){ - this.currentPageTable = 1 - } - - let offsetVal = (this.currentPageTable-1)*this.eachPageTable - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTable = true - - // if(!this.tableFilter.tableSearchText.trim()){ - // this.tableWhere = "" - // } - - //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null - TaosRestful.selectData(this.tableName, this.theDB, payload, fields=this.tableFilter.fields, where=this.tableWhere - , limit=this.eachPageTable, offset=offsetVal, desc=this.Torder, startTime=startTime, endTime=endTime) - .then(data =>{ - if(data.res){ - //成功 - if(data.data.length != 0){ - //有数据 - this.$message({ - message: '获取成功', - type: 'success', - duration:1000 - }); - if(isFirst){ - this.tableLabelItems = Object.keys(data.data[0]) - } - this.tableLabel = Object.keys(data.data[0]) - this.tableFilter.fields = Object.keys(data.data[0]) - this.tableData = data.data - this.totalTable = data.count - } else { - this.tableLabel = [] - this.tableData = data.data - this.totalTable = data.count - this.$message({ - message: '无数据', - type: 'warning', - duration:1000 - }); - } - } - this.loadingTable = false - }) - }, - surTableFilter(){ - this.selectSurperData(0) - }, - handleClickSurperT(val) { - if(val){ - this.clearSurperTable() - this.surperTableName = val.name - this.selectSurperData(true) - } - }, - handleClickT(val) { - if(val){ - this.clearTable() - this.tableName = val.table_name - this.selectTData(true) - } - }, - paginationSurperChange(){ - this.selectSurperData(false) - }, - paginationChange(){ - this.selectTData(false) - }, - editSurperT(val) { - console.log(val) - }, - deleteSurperT(val) { - this.$confirm('确认删除超级表' + val + "吗？") - .then(_ => { - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingSurperList = true - - //TODO没测试过 - TaosRestful.dropTable(val, this.theDB, payload).then(data => { - - if(data.res){ - //成功 - this.$message({ - message: '删除成功', - type: 'success', - duration:500 - }); - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:500 - }); - } - this.loadingSurperList = false - this.freshSurperTables() - }) - - }) - .catch(_ => { - this.$message({ - message: '操作已取消', - type: 'warning', - duration:500 - }); - }); - }, - editT(val) { - console.log(val) - }, - deleteT(val) { - this.$confirm('确认删除表' + val + "吗？") - .then(_ => { - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - this.loadingTableList = true - - //TODO没测试过 - TaosRestful.dropTable(val, this.theDB, payload).then(data => { - - if(data.res){ - //成功 - this.$message({ - message: '删除成功', - type: 'success', - duration:500 - }); - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:500 - }); - } - this.loadingTableList = false - this.freshTables() - }) - - }) - .catch(_ => { - this.$message({ - message: '操作已取消', - type: 'warning', - duration:500 - }); - }); - }, - sendSQL(){ - let payload = { - ip:this.theLink.host, - port:this.theLink.port, - user:this.theLink.user, - password:this.theLink.password - } - // console.log(this.theDB) - TaosRestful.rawSqlWithDB(this.consoleInput,this.theDB,payload).then(data => { - if(data.res){ - // let info = '' - // info += `数据数量: ${data.count}
` - // info += `数据列: ${data.head}
` - // info += `数据: ${data.data}
` - this.$message({ - message: '执行成功', - type: 'success', - duration:500 - }); - this.consoleResult = data - } else { - this.$message({ - message: data.msg, - type: 'error', - duration:1000 - }); - } - - }) - }, - closeSuperTdialog(){ - this.SuperTdialogText = "" - this.SuperTdialog = false - }, - closeTdialog(){ - this.TdialogText = "" - this.Tdialog = false - }, - STChooseAll(){ - this.surperTableFilter.fields = this.surperTableLabelItems - }, - STChooseReverse(){ - let newFields = this.surperTableLabelItems.filter((item) => { - return this.surperTableFilter ? this.surperTableFilter.fields.indexOf(item) == -1 : false; - }) - this.surperTableFilter.fields = newFields - }, - TChooseAll(){ - this.tableFilter.fields = this.tableLabelItems - }, - TChooseReverse(){ - let newFields = this.tableLabelItems.filter((item) => { - return this.tableLabelItems.fields? this.tableLabelItems.fields.indexOf(item) == -1: false; - }) - this.tableFilter.fields = newFields - } - - } - }) - - - \ No newline at end of file diff --git a/renderer/js/electronStore.js b/renderer/js/electronStore.js new file mode 100644 index 0000000..69052f7 --- /dev/null +++ b/renderer/js/electronStore.js @@ -0,0 +1,42 @@ +//持久化存储 +const Store = require('electron-store'); + +let store = new Store(); + +const getLinks = () => { + let links = store.get("links"); + links = links ? links : [] + return links; +} + +const setLinks = (links) => { + return store.set("links", links); +} + +const deleteALink = (key) => { + let links = getLinks(); + links.splice(key, 1) + return setLinks(links) +} + +const addALink = (link) => { + //添加一个连接，如果本地存了，就更新，没存新增 + let links = getLinks() + for (let i = 0; i < links.length; i++) { + if (link.host === links[i].host && link.port === links[i].port) { + //更新 + links[i] = link + return setLinks(links) + } + } + //新增 + links.push(link) + return setLinks(links) +} + +Vue.prototype.$electronStore = { + getLinks, + setLinks, + deleteALink, + addALink +}; diff --git a/renderer/js/index.js b/renderer/js/index.js new file mode 100644 index 0000000..119ba9d --- /dev/null +++ b/renderer/js/index.js @@ -0,0 +1,915 @@ +const TaosRestful = require('./taosrestful_.js') +require('./electronStore.js') +const {TouchBarScrubber} = require('electron') + +new Vue({ + el: '#app', + mounted: function () { + let _this = this; + this.$data.links = this.$electronStore.getLinks() + this.$nextTick(() => { + window.onresize = function listen() { + _this.contentTableHeight = window.innerHeight * 0.74; + } + }) + }, + data: function () { + return { + dbInfo: '', + consoleResult: '', + loadingLinks: false, + drawer: true, + addLinkDialog: false, + addOrEditTitle: '新建连接', + linkForm: { + name: "", + host: "", + port: "", + user: "", + password: "", + }, + activeTab: "1", + + surperTableFilterCopy: {}, + + surperTableFilter: { + fields: [], + surperDateRange: [], + surperTSearchText: "", + surperTSearchColumn: "", + }, + + tableFilterCopy: {}, + tableFilter: { + fields: [], + dateRange: [], + tableSearchText: "", + tableSearchColumn: "", + }, + surperWhere: "", + tableWhere: "", + + tableFilterDialog: false, + surperTableFilterDialog: false, + + contentTableHeight: window.innerHeight * 0.74, + + surperTables: [], //超级表list + surperTableData: [], + surperTableName: "", + totalSurperTable: 0, + surperTableLabelItems: [], + surperTableLabel: [], + loadingSurperList: false, + loadingSurperTable: false, + + tables: [], //表list + tableData: [], + tableName: "", + totalTable: 0, + tableLabelItems: [], + tableLabel: [], + loadingTableList: false, + loadingTable: false, + + eachPageSurperTable: 30, + currentPageSurperTable: 1, + eachPageTable: 30, + currentPageTable: 1, + + addDBDialogLinkKey: 0, + addDBDialog: false, + addDBname: "", + addDBcomp: "", + addDBreplica: "", + addDBkeep: "", + addDBupdate: "", + addDBquorum: "", + addDBblocks: "", + + searchIcon: true, + freshIcon: true, + links: [], + theLink: {}, //当前连接 + theDB: "", //当前数据库 + + SuperTdialog: false, + SuperTdialogText: "", + Tdialog: false, + TdialogText: "", + + surperTorder: "ASC", + Torder: "ASC", + consoleInput: "", + marks: { + 0: '0', + 365: '365', + 36500: '36500' + } + } + }, + methods: { + beforeClosedrawer() { + if (this.theDB) { + this.drawer = false + } else { + this.$message({ + message: '请选择数据库', + type: 'warning', + duration: 1000 + }); + } + }, + cancelAddLink() { + this.addLinkDialog = false + this.addOrEditTitle = '新建连接' + this.clearLinkForm(); + }, + clearLinkForm() { + //清空表单 + this.linkForm = { + name: "", + host: "", + port: "", + user: "", + password: "" + } + }, + formatBoolean(data) { + data.forEach(item => { + for (let i in item) { + if (item[i] === true) { + item[i] = 'true' + } else if (item[i] === false) { + item[i] = 'false' + } + } + }) + }, + /** 复制代码成功 */ + clipboardSuccess() { + this.$message({ + message: '复制成功', + type: 'success', + duration: 500 + }); + }, + confirmAddLink(event) { + //新建连接，先连接，如果成功，将payload+name记入本地 + //var tr = new TaosRestful("121.36.56.117","6041","root","msl110918") + let payload = { + ip: this.linkForm.host, + port: this.linkForm.port, + user: this.linkForm.user, + password: this.linkForm.password + } + TaosRestful.showDatabases(payload).then(data => { + //处理返回的数据库数据 + if (data.res) { + + TaosRestful.getVersion(payload).then(_data => { + //连接成功，保存到本地 + this.$electronStore.addALink({ + name: this.linkForm.name, + host: this.linkForm.host, + port: this.linkForm.port, + user: this.linkForm.user, + password: this.linkForm.password, + version: _data + }) + //更新连接列表 + this.links = this.$electronStore.getLinks() + //关闭新建连接的弹窗 + this.addLinkDialog = false + this.addOrEditTitle = '新建连接' + //清空表单 + this.clearLinkForm(); + }) + } else { + //连接失败 + this.$message({ + message: '连接失败', + type: 'error', + duration: 1000 + }); + } + } + ) + }, + deleteLink(key, linkName) { + this.$confirm('确认删除连接' + linkName + "吗？") + .then(_ => { + this.$electronStore.deleteALink(key) + this.links = this.$electronStore.getLinks() + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + }) + }, + freshDB(key) { + let _this = this; + let theLink = this.links[key] + let payload = { + ip: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password + } + this.loadingLinks = true + TaosRestful.showDatabases(payload).then(data => { + this.loadingLinks = false + if (data.res) { + this.$message({ + message: '刷新成功', + type: 'success', + duration: 1000 + }); + this.links[key].dbs = data.data + + TaosRestful.getVersion(payload).then(data => { + theLink.version = data + _this.$data.links[key] = theLink + if (TaosRestful.compareVersion(data, theLink.version)) { + this.$electronStore.addALink({ + name: theLink.name, + host: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password, + version: data + }) + } + }) + + //TODO展开菜单 + + } else { + //连接失败，直接提示 + this.$message({ + message: "连接失败，请稍后重试", + type: 'error', + duration: 1000 + }); + } + }) + }, + addDB(key) { + this.addDBDialogLinkKey = key + this.addDBDialog = true + + this.addDBname = "" + this.addDBcomp = 2 + this.addDBreplica = 1 + this.addDBkeep = 3650 + this.addDBupdate = 0 + this.addDBquorum = 1 + this.addDBblocks = 6 + }, + editDB(key) { + let theLink = this.links[key] + this.linkForm = { + name: theLink.name, + host: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password, + } + this.addOrEditTitle = '编辑连接' + this.addLinkDialog = true + }, + postaddDB() { + let key = this.addDBDialogLinkKey + let theLink = this.links[key] + let payload = { + ip: theLink.host, + port: theLink.port, + user: theLink.user, + password: theLink.password + } + if (this.addDBname) { + if (this.addDBreplica && this.addDBquorum) { + if (this.addDBreplica < this.addDBquorum) { + this.$message({ + message: 'replica应大于等于quorum', + type: 'error', + duration: 1000 + }); + return + } + } + TaosRestful.createDatabase(this.addDBname, payload, safe = true, keep = this.addDBkeep, + update = this.addDBupdate, comp = this.addDBcomp, replica = this.addDBreplica, + quorum = this.addDBquorum, blocks = this.addDBblocks, theLink.version).then(data => { + if (data.res) { + //新增成功 + this.$message({ + message: '添加成功', + type: 'success', + duration: 1000 + }); + this.freshDB(key) + this.addDBDialog = false + } else { + //添加失败 + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + }) + } else { + this.$message({ + message: '请填写内容', + type: 'warning', + duration: 1000 + }); + } + }, + deleteDB(link, dbName, key) { + this.$confirm('确认删除数据库' + dbName + "吗？") + .then(_ => { + let payload = { + ip: link.host, + port: link.port, + user: link.user, + password: link.password + } + this.loadingLinks = true + + TaosRestful.dropDatabase(dbName, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 1000 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingLinks = false + this.freshDB(key) + }) + }) + }, + makeDbInfo(dbs, dbName) { + // console.log(dbs) + let info = '无法获取数据库信息' + dbs.forEach(item => { + if (item['name'] === dbName) { + info = `数据库名: ${dbName}
` + info += `创建时间: ${item['created_time']}
` + info += `update: ${item['update'] > 0 ? (item['update'] === 1 ? '允许整行更新' : '允许部分列更新' ) : '不允许更新'}
` + info += `cache(MB): ${item['cache(MB)']}
` + info += `cachelast: ${item['cachelast']}
` + info += `comp: ${item['comp']}
` + info += `days: ${item['days']}
` + info += `fsync: ${item['fsync']}
` + info += `keep1,keep2,keep(D): ${item['keep1,keep2,keep(D)']}
` + info += `maxrows: ${item['maxrows']}
` + info += `minrows: ${item['minrows']}
` + info += `ntables: ${item['ntables']}
` + info += `quorum: ${item['quorum']}
` + info += `replica: ${item['replica']}
` + info += `status: ${item['status']}
` + info += `vgroups: ${item['vgroups']}
` + info += `wallevel: ${item['wallevel']}
` + info += `precision: ${item['precision']}
` + } + }) + return info + }, + alartDB(link, dbName) { + //切换数据库前先清空表 + this.dbInfo = this.makeDbInfo(link.dbs, dbName) + this.surperTables = [] + this.clearSurperTable() + this.tables = [] + this.clearTable() + + //记录进入的数据库 + this.theLink = link + this.theDB = dbName + + //更新超级表页 + this.drawer = false + this.activeTab = "1" + this.freshSurperTables() + }, + searchSurperTList() { + this.SuperTdialog = false + this.surperTables = [] + this.clearSurperTable() + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + TaosRestful.showSuperTables(this.theDB, payload, like = this.SuperTdialogText).then(data => { + if (data.res) { + //拉取超级表成功 + this.$message({ + message: '查找成功', + type: 'success', + duration: 1000 + }); + this.surperTables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + this.freshSurperTables() + } + this.SuperTdialogText = "" + this.loadingSurperList = false + }) + + }, + freshSurperTList() { + this.surperTables = [] + this.clearSurperTable() + this.freshSurperTables() + }, + searchTList() { + this.Tdialog = false + this.tables = [] + this.clearTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + TaosRestful.showTables(this.theDB, payload, like = this.TdialogText).then(data => { + if (data.res) { + //拉取表成功 + this.$message({ + message: '查找成功', + type: 'success', + duration: 1000 + }); + this.tables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + this.freshTables() + + } + this.TdialogText = "" + this.loadingTableList = false + }) + }, + freshTList() { + this.tables = [] + this.clearTable() + this.freshTables() + }, + clearSurperTable() { + this.surperTableName = "" + this.totalSurperTable = 0 + this.surperTableData = [] + this.surperTableLabel = [] + this.surperTableFilter = { + fields: [], + surperDateRange: [], + surperTSearchText: "", + surperTSearchColumn: "", + } + }, + clearTable() { + this.tableName = "" + this.totalTable = 0 + this.tableData = [] + this.tableLabel = [] + this.tableFilter = { + fields: [], + dateRange: [], + tableSearchText: "", + tableSearchColumn: "", + } + }, + freshSurperTables() { + //清理超级表列表 + this.surperTables = [] + //清理选中的超级表和具体数据 + this.clearSurperTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + TaosRestful.showSuperTables(this.theDB, payload).then(data => { + if (data.res) { + this.surperTables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingSurperList = false + }) + }, + freshTables() { + //清理表列表 + this.tables = [] + //清理选中的表和具体数据 + this.clearTable() + + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + TaosRestful.showTables(this.theDB, payload).then(data => { + if (data.res) { + this.tables = data.data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingTableList = false + }) + }, + handleSwichTab(tab) { + switch (tab.name) { + case "1": + //超级表 + this.freshSurperTables() + break; + case "2": + //表 + this.freshTables() + break; + case "3": + //控制台 + break; + case "4": + //数据库属性 + break; + } + }, + openSurperTableFilterD() { + this.surperTableFilterDialog = true + this.surperTableFilterCopy = JSON.parse(JSON.stringify(this.surperTableFilter)) + }, + concelSurperTableFilter() { + this.surperTableFilterDialog = false + this.surperTableFilter = this.surperTableFilterCopy + }, + postSurperTableFilter() { + this.surperTableFilterDialog = false + this.selectSurperData(false) + }, + openTableFilterD() { + this.tableFilterDialog = true + this.tableFilterCopy = JSON.parse(JSON.stringify(this.tableFilter)) + }, + concelTableFilter() { + this.tableFilterDialog = false + this.tableFilter = this.tableFilterCopy + }, + postTableFilter() { + this.tableFilterDialog = false + this.selectTData(false) + }, + searchSurperText() { + if (this.surperTableFilter.surperTSearchColumn && this.surperTableFilter.surperTSearchText.trim()) { + // this.surperWhere = this.surperTSearchColumn + " > " + this.surperTSearchText.trim()+"%" + // this.clearSurperTable() + let surperTSearchText = this.surperTableFilter.surperTSearchText.trim() + if (!isNaN(surperTSearchText)) { + this.surperWhere = this.surperTableFilter.surperTSearchColumn + " = " + surperTSearchText + } else { + this.surperWhere = this.surperTableFilter.surperTSearchColumn + " = '" + surperTSearchText + "'" + } + + this.selectSurperData(false) + } else { + this.surperWhere = "" + this.$message({ + message: '请填写正确', + type: 'warning', + duration: 1000 + }); + this.selectSurperData(false) + } + }, + searchTableText() { + if (this.tableFilter.tableSearchColumn && this.tableFilter.tableSearchText.trim()) { + + let tableSearchText = this.tableFilter.tableSearchText.trim() + if (!isNaN(tableSearchText)) { + this.tableWhere = this.tableFilter.tableSearchColumn + " = " + tableSearchText + } else { + this.tableWhere = this.tableFilter.tableSearchColumn + " = '" + tableSearchText + "'" + } + + this.selectTData(false) + } else { + this.tableWhere = "" + this.$message({ + message: '请填写正确', + type: 'warning', + duration: 1000 + }); + this.selectTData(false) + } + }, + selectSurperData(isFirst, isResetPage) { + + //处理时间范围 + let startTime = null + let endTime = null + if (this.surperTableFilter.surperDateRange) { + startTime = this.surperTableFilter.surperDateRange[0]; + endTime = this.surperTableFilter.surperDateRange[1]; + } + + //是否需要重置分页 + if (isResetPage) { + this.currentPageSurperTable = 1 + } + + let offsetVal = (this.currentPageSurperTable - 1) * this.eachPageSurperTable + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperTable = true + + //处理查询数据 + // if(!this.surperTableFilter.surperTSearchText.trim()){ + // this.surperWhere = "" + // } + + //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null + TaosRestful.selectData(this.surperTableName, this.theDB, payload, fields = this.surperTableFilter.fields, + where = this.surperWhere, limit = this.eachPageSurperTable, offset = offsetVal, + desc = this.surperTorder, startTime = startTime, endTime = endTime) + .then(data => { + if (data.res) { + //成功 + if (data.data.length !== 0) { + if (isFirst) { + this.surperTableLabelItems = Object.keys(data.data[0]) + } + this.surperTableLabel = Object.keys(data.data[0]) + this.surperTableFilter.fields = Object.keys(data.data[0]) + this.formatBoolean(data.data) + this.surperTableData = data.data + this.totalSurperTable = data.count + } else { + this.surperTableLabel = [] + this.formatBoolean(data.data) + this.surperTableData = data.data + this.totalSurperTable = data.count + this.$message({ + message: '无数据', + type: 'warning', + duration: 1000 + }); + } + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + this.loadingSurperTable = false + + }) + }, + selectTData(isFirst, isResetPage = false) { + + //处理时间范围 + let startTime = null + let endTime = null + if (this.tableFilter.dateRange) { + startTime = this.tableFilter.dateRange[0]; + endTime = this.tableFilter.dateRange[1]; + } + + if (isResetPage) { + this.currentPageTable = 1 + } + + let offsetVal = (this.currentPageTable - 1) * this.eachPageTable + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTable = true + + // if(!this.tableFilter.tableSearchText.trim()){ + // this.tableWhere = "" + // } + + //tableName,dbName,payload,fields=null,where=null,limit =null,offset = null,desc =null,startTime=null,endTime=null + TaosRestful.selectData(this.tableName, this.theDB, payload, fields = this.tableFilter.fields, + where = this.tableWhere, limit = this.eachPageTable, offset = offsetVal, + desc = this.Torder, startTime = startTime, endTime = endTime) + .then(data => { + if (data.res) { + //成功 + if (data.data.length !== 0) { + if (isFirst) { + this.tableLabelItems = Object.keys(data.data[0]) + } + this.tableLabel = Object.keys(data.data[0]) + this.tableFilter.fields = Object.keys(data.data[0]) + this.formatBoolean(data.data) + this.tableData = data.data + this.totalTable = data.count + } else { + this.tableLabel = [] + this.formatBoolean(data.data) + this.tableData = data.data + this.totalTable = data.count + this.$message({ + message: '无数据', + type: 'warning', + duration: 1000 + }); + } + } + this.loadingTable = false + }) + }, + surTableFilter() { + this.selectSurperData(0) + }, + handleClickSurperT(val) { + if (val) { + this.clearSurperTable() + this.surperTableName = val.name + this.selectSurperData(true) + } + }, + handleClickT(val) { + if (val) { + this.clearTable() + this.tableName = val.table_name + this.selectTData(true) + } + }, + paginationSurperChange() { + this.selectSurperData(false) + }, + paginationChange() { + this.selectTData(false) + }, + editSurperT(val) { + console.log(val) + }, + deleteSurperT(val) { + this.$confirm('确认删除超级表' + val + "吗？") + .then(_ => { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingSurperList = true + + //TODO没测试过 + TaosRestful.dropTable(val, this.theDB, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 500 + }); + } + this.loadingSurperList = false + this.freshSurperTables() + }) + + }) + }, + editT(val) { + console.log(val) + }, + deleteT(table_name) { + this.$confirm('确认删除表' + table_name + "吗？") + .then(_ => { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + this.loadingTableList = true + + //TODO没测试过 + TaosRestful.dropTable(table_name, this.theDB, payload).then(data => { + + if (data.res) { + //成功 + this.$message({ + message: '删除成功', + type: 'success', + duration: 500 + }); + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 500 + }); + } + this.loadingTableList = false + this.freshTables() + }) + }) + }, + sendSQL() { + let payload = { + ip: this.theLink.host, + port: this.theLink.port, + user: this.theLink.user, + password: this.theLink.password + } + TaosRestful.rawSql(this.consoleInput, payload).then(data => { + if (data.res) { + this.consoleResult = data + } else { + this.$message({ + message: data.msg, + type: 'error', + duration: 1000 + }); + } + }) + }, + closeSuperTdialog() { + this.SuperTdialogText = "" + this.SuperTdialog = false + }, + closeTdialog() { + this.TdialogText = "" + this.Tdialog = false + }, + STChooseAll() { + this.surperTableFilter.fields = this.surperTableLabelItems + }, + STChooseReverse() { + let newFields = this.surperTableLabelItems.filter((item) => { + return this.surperTableFilter ? this.surperTableFilter.fields.indexOf(item) == -1 : false; + }) + this.surperTableFilter.fields = newFields + }, + TChooseAll() { + this.tableFilter.fields = this.tableLabelItems + }, + TChooseReverse() { + let newFields = this.tableLabelItems.filter((item) => { + return this.tableLabelItems.fields ? this.tableLabelItems.fields.indexOf(item) == -1 : false; + }) + this.tableFilter.fields = newFields + } + + } +}) + + diff --git a/renderer/js/taosrestful.js b/renderer/js/taosrestful.js new file mode 100644 index 0000000..9eda859 --- /dev/null +++ b/renderer/js/taosrestful.js @@ -0,0 +1,289 @@ +'use strict' +const axios = require('axios') + +module.exports = class TaosRestful { + constructor(ip = 'localhost', port = '6041', user = 'root', password = "taosdata", timeout = 0) { + this.ip = ip + this.port = port + this.user = user + this.password = password + this.database = 'log' + this.timeout = timeout * 1000 + } + + async sendRequest(sqlStr) { + try { + let res = await axios.post(`http://${this.ip}:${this.port}/rest/sql`, sqlStr, { + auth: { + username: this.user, + password: this.password + }, + timeout: this.timeout + }) + + if (res.data.status == 'succ') { + // console.log(res.data.data) + // console.log(res.data.rows) + // console.log(res.data.head) + let head = res.data.head + let resData = res.data.data.map(item => Object.fromEntries(head.map((a, b) => [a, item[b]]))) + return {'res': true, 'count': res.data.rows, 'data': resData} + } else { + return {'res': false, 'msg': res.data.desc, 'code': res.data.code} + } + } catch (err) { + if (err.response) { + return {'res': false, 'msg': err.response.data.desc, 'code': err.response.data.code} + } else { + return {'res': false, 'msg': 'connect error', 'code': -1} + } + + } + + } + + showDatabases() { + return this.sendRequest('SHOW DATABASES') + } + + testConnect() { + return this.sendRequest('SELECT SERVER_VERSION()').then(a => { + if (a.res === false && a.code === -1) { + return false + } else { + return true + } + } + ) + } + + getVersion() { + return this.sendRequest('SELECT SERVER_VERSION()').then(a => { + if (a.res === false) { + return a.msg + } else { + return a.data[0]['server_version()'] + } + } + ) + } + + //创建新的数据库 + createDatabase(dbName, safe = true, keep = null, update = false, comp = null, replica = null, quorum = null, blocks = null) { + let sqlStr = 'CREATE DATABASE ' + if (safe) { + sqlStr += 'IF NOT EXISTS ' + } + sqlStr += dbName + + if (keep != null) { + sqlStr += ` KEEP ${keep}` + } + if (comp != null) { + sqlStr += ` COMP ${comp}` + } + if (replica != null) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum != null) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks != null) { + sqlStr += ` BLOCKS ${blocks}` + } + if (update) { + sqlStr += ` UPDATE 1` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr) + } + + alterDatabase(dbName, keep = null, comp = null, replica = null, quorum = null, blocks = null) { + let sqlStr = 'ALTER DATABASE ' + sqlStr += dbName + if (keep != null) { + sqlStr += ` KEEP ${keep}` + } + if (comp != null) { + sqlStr += ` COMP ${comp}` + } + if (replica != null) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum != null) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks != null) { + sqlStr += ` BLOCKS ${blocks}` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr) + } + + useDatabase(dbName) { + this.database = dbName + } + + dropDatabase(dbName, safe = true) { + // console.log(`DROP DATABASE ${safe?'IF EXISTS':''} ${dbName}`) + return this.sendRequest(`DROP DATABASE ${safe ? 'IF EXISTS' : ''} ${dbName}`) + } + + showSuperTables(dbName = null, like = null) { + let dbN = dbName ? dbName : this.database + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbN}.STABLES ${likeStr}`) + } + + showTables(dbName = null, like = null) { + let dbN = dbName ? dbName : this.database + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbN}.TABLES ${likeStr}`) + } + + disTable(tableName, dbName = null) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`DESCRIBE ${dbN}.${tableName}`) + } + + dropTable(tableName, dbName = null, safe = false) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbN}.${tableName}`) + } + + insertData(tableName, data, dbName = null) { + let dbN = dbName ? dbName : this.database + let fields = '' + let values = '' + for (const [key, value] of Object.entries(data)) { + fields += key + ',' + values += value + ',' + } + // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` ) + return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`) + } + + timeWhere(primaryKey, where, startTime, endTime) { + where = where || '' + if (where) { + where += startTime ? ` and ${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } else { + where += startTime ? `${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } + return where + } + + countData(tableName, where = '', dbName = null, startTime = null, endTime = null) { + return this.disTable(tableName, dbName).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + return this.countDataIn(tableName, primaryKey, where, dbName, startTime, endTime) + }) + } + + countDataIn(tableName, primaryKey, where = '', dbName = null, startTime = null, endTime = null) { + where = this.timeWhere(primaryKey, where, startTime, endTime) + let dbN = dbName ? dbName : this.database + let sqlStr = 'SELECT ' + let fieldStr = 'count(*)' + sqlStr += fieldStr + ` FROM ${dbN}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr).then(result => { + if (result.res && result.data.length > 0) { + return new Promise((resolve, reject) => { + resolve(result.data[0]['count(*)']) + }) + } else { + return new Promise((resolve, reject) => { + resolve(0) + }) + } + }) + + } + + //查询数据 + selectData(tableName, fields = null, where = '', limit = null, offset = null, desc = null, dbName = null, startTime = null, endTime = null) { + return this.disTable(tableName, dbName).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + + where = this.timeWhere(primaryKey, where, startTime, endTime) + let dbN = dbName ? dbName : this.database + let sqlStr = 'SELECT ' + let fieldStr = '*' + if (fields && fields.length > 0) { + fieldStr = '' + fields.forEach(function (field) { + fieldStr += field + ',' + }); + fieldStr = fieldStr.slice(0, -1) + } + sqlStr += fieldStr + ` FROM ${dbN}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + if (desc === 'DESC') { + sqlStr += ` ORDER BY ${primaryKey} ${desc} ` + } + + if (limit != null) { + sqlStr += ` LIMIT ${limit} ` + } + if (offset != null) { + sqlStr += ` OFFSET ${offset} ` + } + + // console.log(sqlStr) + if (limit != null) { + return this.sendRequest(sqlStr).then(res => { + // console.log(res) + return this.countDataIn(tableName, primaryKey, where, dbName, startTime, endTime).then(count => { + res.count = count + return new Promise((resolve, reject) => { + resolve(res) + }) + }) + }) + } else { + return this.sendRequest(sqlStr) + } + + }) + + + } + + rawSql(sqlStr) { + return this.sendRequest(sqlStr) + } + + rawSqlWithDB(sqlStr, dbName = null) { + let dbN = dbName ? dbName : this.database + return this.sendRequest(`USE ${dbN}`).then(a => { + return this.sendRequest(sqlStr) + }) + } +} + diff --git a/renderer/js/taosrestful_.js b/renderer/js/taosrestful_.js new file mode 100644 index 0000000..b4b75f0 --- /dev/null +++ b/renderer/js/taosrestful_.js @@ -0,0 +1,265 @@ +const axios = require('axios') +const { formatResult } = require('./versionAdapter') + +module.exports = { + async sendRequest(sqlStr, payload) { + // console.log(sqlStr) + try { + if (!payload.timeout) { + payload.timeout = 10000; + } + let res = await axios.post(`http://${payload.ip}:${payload.port}/rest/sql`, sqlStr, { + auth: { + username: payload.user, + password: payload.password + }, + timeout: payload.timeout + }) + + res = formatResult(res, sqlStr) + + if (res.data.status === 'succ') { + // console.log(res.data.data) + // console.log(res.data.rows) + // console.log(res.data.head) + let head = res.data.head + let resData = res.data.data.map(item => Object.fromEntries(head.map((a, b) => [a, item[b]]))) + return {'res': true, 'count': res.data.rows, 'data': resData} + } else { + return {'res': false, 'msg': res.data.desc, 'code': res.data.code} + } + } catch (err) { + if (err.response) { + return {'res': false, 'msg': err.response.data.desc, 'code': err.response.data.code} + } else { + return {'res': false, 'msg': '连接错误', 'code': -1} + } + } + + }, + showDatabases(payload) { + return this.sendRequest('SHOW DATABASES', payload) + }, + testConnect(payload) { + return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a => { + return !(a.res === false && a.code === -1); + } + ) + }, + getVersion(payload) { + //获取服务器版本 + return this.sendRequest('SELECT SERVER_VERSION()', payload).then(a => { + return a.res === false ? 'unkown' : a.data[0]['server_version()']; + } + ) + }, + //添加数据库 + createDatabase(dbName, payload, safe = true, keep = null, update = 0, comp = null, + replica = null, quorum = null, blocks = null, version) { + let sqlStr = 'CREATE DATABASE ' + if (safe) { + sqlStr += 'IF NOT EXISTS ' + } + sqlStr += dbName + + if (keep) { + sqlStr += ` KEEP ${keep}` + } + if (comp) { + sqlStr += ` COMP ${comp}` + } + if (replica) { + sqlStr += ` REPLICA ${replica}` + } + if (quorum) { + sqlStr += ` QUORUM ${quorum}` + } + if (blocks) { + sqlStr += ` BLOCKS ${blocks}` + } + if (update) { + if (this.compareVersion(version, '2.0.8.0')) { + if (update == 2) { + if (this.compareVersion(version, '2.1.7.0')) { + sqlStr += ` UPDATE ${update}` + } else { + console.log("update参数暂不支持：" + version + "版本") + } + } else { + sqlStr += ` UPDATE ${update}` + } + } else { + console.log("update参数暂不支持：" + version + "版本") + } + } + return this.sendRequest(sqlStr, payload) + }, +// alterDatabase(dbName,keep=null,comp=null,replica=null,quorum=null,blocks=null){ +// let sqlStr = 'ALTER DATABASE ' +// sqlStr += dbName +// if(keep != null){ +// sqlStr += ` KEEP ${keep}` +// } +// if(comp != null){ +// sqlStr += ` COMP ${comp}` +// } +// if(replica != null){ +// sqlStr += ` REPLICA ${replica}` +// } +// if(quorum != null){ +// sqlStr += ` QUORUM ${quorum}` +// } +// if(blocks != null){ +// sqlStr += ` BLOCKS ${blocks}` +// } +// // console.log(sqlStr) +// return this.sendRequest(sqlStr) +// }, +// useDatabase(dbName){ +// this.database = dbName +// }, + dropDatabase(dbName, payload, safe = true) { + return this.sendRequest(`DROP DATABASE ${safe ? 'IF EXISTS' : ''} ${dbName}`, payload) + }, + showSuperTables(dbName, payload, like = null) { + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbName}.STABLES ${likeStr}`, payload) + }, + showTables(dbName, payload, like = null) { + let likeStr = like ? ` LIKE '%${like}%'` : '' + return this.sendRequest(`SHOW ${dbName}.TABLES ${likeStr}`, payload) + }, + disTable(tableName, dbName, payload) { + return this.sendRequest(`DESCRIBE ${dbName}.${tableName}`, payload) + }, + dropTable(tableName, dbName, payload, safe = false) { + return this.sendRequest(`DROP TABLE ${safe?'IF EXISTS':''} ${dbName}.${tableName}`, payload) + }, + insertData(tableName, data, dbName = null) { + let dbN = dbName ? dbName : this.database + let fields = '' + let values = '' + for (const [key, value] of Object.entries(data)) { + fields += key + ',' + values += value + ',' + } + // console.log(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})` ) + return this.sendRequest(`INSERT INTO ${dbN}.${tableName} (${fields.slice(0,-1)}) VALUES (${values.slice(0,-1)})`) + }, + timeWhere(primaryKey, where, startTime, endTime) { + where = where || '' + if (where) { + where += startTime ? ` and ${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } else { + where += startTime ? `${primaryKey} > '${startTime}' ` : '' + if (where) { + where += endTime ? ` and ${primaryKey} < '${endTime}' ` : '' + } else { + where += endTime ? `${primaryKey} < '${endTime}' ` : '' + } + } + return where + }, + //查询数据 + selectData(tableName, dbName, payload, fields = null, where = null, limit = null, + offset = null, desc = null, startTime = null, endTime = null) { + //首先查询一次，获取表的整体情况 + return this.disTable(tableName, dbName, payload).then(res => { + let primaryKey = 'ts' + if (res.res && res.data.length > 0) { + //获取第一项，时间戳 + primaryKey = res.data[0].Field + } else { + return {'res': false, 'msg': 'distable error', 'code': 99} + } + + //组装where子句 //TODO + where = this.timeWhere(primaryKey, where, startTime, endTime) + let sqlStr = 'SELECT ' + let fieldStr = '*' + if (fields && fields.length > 0) { + fieldStr = '' + fields.forEach(function (field) { + fieldStr += field + ',' + }); + fieldStr = fieldStr.slice(0, -1) + } + sqlStr += fieldStr + ` FROM ${dbName}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + if (desc === 'DESC') { + sqlStr += ` ORDER BY ${primaryKey} ${desc} ` + } + + if (limit != null) { + sqlStr += ` LIMIT ${limit} ` + } + if (offset != null) { + sqlStr += ` OFFSET ${offset} ` + } + + //把总数数出来 + if (limit != null) { + return this.sendRequest(sqlStr, payload).then(res => { + return this.countDataIn(tableName, dbName, primaryKey, payload, where).then(count => { + res.count = count + return new Promise((resolve, reject) => { + resolve(res) + }) + }) + }) + } else { + return this.sendRequest(sqlStr, payload) + } + + }) + + }, + countDataIn(tableName, dbName, primaryKey, payload, where = '', startTime = null, endTime = null) { + where = this.timeWhere(primaryKey, where, startTime, endTime) + let sqlStr = 'SELECT ' + let fieldStr = 'count(*)' + sqlStr += fieldStr + ` FROM ${dbName}.${tableName} ` + if (where) { + sqlStr += ` WHERE ${where} ` + } + // console.log(sqlStr) + return this.sendRequest(sqlStr, payload).then(result => { + if (result.res && result.data.length > 0) { + return new Promise((resolve, reject) => { + resolve(result.data[0]['count(*)']) + }) + } else { + return new Promise((resolve, reject) => { + resolve(0) + }) + } + }) + }, + rawSql(sqlStr, payload) { + return this.sendRequest(sqlStr, payload) + }, + compareVersion(serverVersion, targetVersion) { + if (serverVersion == targetVersion) { + return true; + } + let serverArray = serverVersion.split("."); + let targetArray = targetVersion.split("."); + let length = Math.min(serverArray.length, targetArray.length); + for (let i = 0; i < length; i++) { + if (serverArray[i] > targetArray[i]) { + return true; + } else if (serverArray[i] < targetArray[i]) { + return false; + } + } + return false; + } +} + diff --git a/renderer/js/versionAdapter.js b/renderer/js/versionAdapter.js new file mode 100644 index 0000000..59a3418 --- /dev/null +++ b/renderer/js/versionAdapter.js @@ -0,0 +1,26 @@ +module.exports = { + formatResult(res, sql) { + if (res.data.status !== undefined) { + // Version 2.x + return res + } + + if (res.data.code === 0) { + res.data.status = 'succ' + res.data.head = res.data.column_meta.map(item => item[0]) + } else { + res.data.status = 'error' + } + + if ( + /show /i.test(sql) && + /.stables/i.test(sql) && + res.data.head.length === 1 && + res.data.head[0] === 'stable_name' + ) { + res.data.head[0] = 'name' + } + + return res + } +} diff --git a/renderer/js/vue-clipboard2/vue-clipboard.min.js b/renderer/js/vue-clipboard2/vue-clipboard.min.js new file mode 100644 index 0000000..d7d417f --- /dev/null +++ b/renderer/js/vue-clipboard2/vue-clipboard.min.js @@ -0,0 +1 @@ +(function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i