Add run query command.

package.json

@@ -150,6 +150,12 @@
 				"title": "%command.query.rename%",
 				"category": "MySQL"
 			},
+			{
+				"command": "mysql.query.run",
+				"title": "%command.query.run%",
+				"icon": "$(run)",
+				"category": "MySQL"
+			},
 			{
 				"command": "mysql.connection.add",
 				"title": "%command.connection.add%",
@@ -589,6 +595,11 @@
 					"when": "view =~ /cweijan.+?ql/ && viewItem == query",
 					"group": "2_mysql@0"
 				},
+				{
+					"command": "mysql.query.run",
+					"when": "view =~ /cweijan.+?ql/ && viewItem == query",
+					"group": "2_mysql@0"
+				},
 				{
 					"command": "mysql.refresh",
 					"when": "view =~ /cweijan.+?ql/ && viewItem =~ /^(esConnection|ftpConnection|ftpFolder)$/",
@@ -629,6 +640,11 @@
 					"when": "view =~ /cweijan.+?ql/ && viewItem == queryGroup",
 					"group": "inline@0"
 				},
+				{
+					"command": "mysql.query.run",
+					"when": "view =~ /cweijan.+?ql/ && viewItem == query",
+					"group": "inline@0"
+				},
 				{
 					"command": "mysql.template.user",
 					"when": "view =~ /cweijan.+?ql/ && viewItem == userGroup",

package.nls.json

@@ -7,6 +7,7 @@
 	"command.diagram.add": "Create Diagram",
 	"command.query.add": "Create Query",
 	"command.query.rename": "Rename Query",
+	"command.query.run": "Run This Query",
 	"command.diagram.open": "Open Diagram",
 	"command.diagram.drop": "Drop Diagram",
 	"command.connection.add": "Add Connection",

package.nls.zh-cn.json

@@ -7,6 +7,7 @@
 	"command.diagram.add": "新建实体图",
 	"command.query.add": "新建查询",
 	"command.query.rename": "重命名查询",
+	"command.query.run": "执行该查询",
 	"command.diagram.open": "打开实体图",
 	"command.diagram.drop": "删除实体图",
 	"command.connection.add": "连接数据库",

src/extension.ts

@@ -201,6 +201,9 @@ export function activate(context: vscode.ExtensionContext) {
                         });
                     }
                 },
+                "mysql.query.run": (queryNode: QueryNode) => {
+                    queryNode.run()
+                },
                 "mysql.query.open": (queryNode: QueryNode) => {
                     queryNode.open()
                 },

src/model/query/queryNode.ts

@@ -1,7 +1,8 @@
 import { Constants, ModelType } from "@/common/constants";
 import { FileManager } from "@/common/filesManager";
 import { DbTreeDataProvider } from "@/provider/treeDataProvider";
-import { renameSync } from "fs";
+import { QueryUnit } from "@/service/queryUnit";
+import { readFileSync, renameSync, writeFileSync } from "fs";
 import * as path from "path";
 import * as vscode from "vscode";
 import { TreeItemCollapsibleState } from "vscode";
@@ -21,6 +22,11 @@ export class QueryNode extends Node {
         }
     }
 
+    public async run() {
+        const content = readFileSync(this.getFilePath(),'utf8')
+        QueryUnit.runQuery(content,this)
+    }
+
     public async open() {
         await vscode.window.showTextDocument(
             await vscode.workspace.openTextDocument(this.getFilePath())