用codemirror实现一个自己的简单hive ql编辑器

Posted zzwlong

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了用codemirror实现一个自己的简单hive ql编辑器相关的知识,希望对你有一定的参考价值。

什么是codemirror已经codemirror能干什么在这就不多说了,直接看官方文档http://codemirror.net/。首先去现在一个最新的codemirror:http://codemirror.net/codemirror.zip

codemirror自身提供了一个可复用的sql mode,里面支持了绝大多数的sql类型:text/x-sqltext/x-mysqltext/x-mariadbtext/x-cassandratext/x-plsqltext/x-mssqltext/x-hivetext/x-pgsqltext/x-gql.

这里我想用text/x-hive编辑高亮和自动完成功能,因为我自己写了一个job调度工具,里面要写一些hive ql去调度执行。

要使用sql mode,页面上需要引入(路径因人而异):

<link rel="stylesheet" href="js/codemirror-5.25.0/lib/codemirror.css"/>  
<script src="js/codemirror-5.25.0/lib/codemirror.js"></script>  
<script src="js/codemirror-5.25.0/mode/sql/sql.js"></script>

如果我们添加自动提示功能,那么还要加入另外两个可复用的插件show-hint喝sql-hint:

<link rel="stylesheet" href="js/codemirror-5.25.0/addon/hint/show-hint.css"/>  
<script src="js/codemirror-5.25.0/addon/hint/show-hint.js"></script>  
<script src="js/codemirror-5.25.0/addon/hint/sql-hint.js"></script>  

如果想让当前编辑行高亮,那么需要加入另一个插件:

<script src="js/codemirror-5.25.0/addon/selection/active-line.js"></script>  

一个完整的jsp页面如下:

<%@ page language="java" pageEncoding="utf-8"%>  
<!doctype html>  
  
<title>CodeMirror: SQL Mode for CodeMirror</title>  
<meta charset="utf-8"/>  
<script src="js/jquery-2.2.3.min.js"></script>  
<link rel="stylesheet" href="js/codemirror-5.25.0/lib/codemirror.css"/>  
<script src="js/codemirror-5.25.0/lib/codemirror.js"></script>  
<script src="js/codemirror-5.25.0/mode/sql/sql.js"></script>  
<link rel="stylesheet" href="js/codemirror-5.25.0/addon/hint/show-hint.css"/>  
<script src="js/codemirror-5.25.0/addon/hint/show-hint.js"></script>  
<script src="js/codemirror-5.25.0/addon/hint/sql-hint.js"></script>  
<script src="js/codemirror-5.25.0/addon/selection/active-line.js"></script>  
<style>  
    .CodeMirror {  
        border-top: 1px solid black;  
        border-bottom: 1px solid black;  
    }  
</style>  
  
<article>  
    <h2>SQL Mode for CodeMirror</h2>  
  
    <form>  
            <textarea id="code" name="code">-- SQL Mode for CodeMirror  
SELECT SQL_NO_CACHE DISTINCT  
        @var1 AS `val1`, @\'val2\', @global.\'sql_mode\',  
        1.1 AS `float_val`, .14 AS `another_float`, 0.09e3 AS `int_with_esp`,  
        0xFA5 AS `hex`, x\'fa5\' AS `hex2`, 0b101 AS `bin`, b\'101\' AS `bin2`,  
        DATE \'1994-01-01\' AS `sql_date`, { T "1994-01-01" } AS `odbc_date`,  
        \'my string\', _utf8\'your string\', N\'her string\',  
        TRUE, FALSE, UNKNOWN  
    FROM DUAL  
    -- space needed after \'--\'  
    # 1 line comment  
    /* multiline  
    comment! */  
    LIMIT 1 OFFSET 0;  
</textarea>  
    </form>  
    <script>  
        window.onload = function () {  
            $.getJSON("job/schema/1",{},function(result){  
                var mime = \'text/x-hive\';  
                window.editor = CodeMirror.fromTextArea(document.getElementById(\'code\'), {  
                    mode: mime,  
                    indentWithTabs: true,  
                    smartIndent: true,  
                    styleActiveLine: true,  
                    lineNumbers: true,  
                    lineWrapping: true,  
                    matchBrackets: true,  
                    autofocus: true,  
                    extraKeys: {"Ctrl-Space": "autocomplete"},  
                    hintOptions: {  
                        tables: result.data  
                    }  
                });  
                window.editor.on("keyup", function (cm, event) {  
                    //所有的字母和\'$\',\'{\',\'.\'在键按下之后都将触发自动完成  
                    if (!cm.state.completionActive &&  
                            ((event.keyCode >= 65 && event.keyCode <= 90 ) || event.keyCode == 52 || event.keyCode == 219 || event.keyCode == 190)) {  
                        CodeMirror.commands.autocomplete(cm, null, {completeSingle: false});  
                    }  
                });  
            });  
        };  
    </script>  
  
</article>

我会在页面加载完成之后发起一个异步请求,获取所有可以智能提示的表名,然后创建编辑器实例,将所有的表数据放到hintOptions的tables属性中:

hintOptions: {  
                      tables: result.data  
                  }

result json形如:

{  
  "resultCode": "00",  
  "description": "操作成功",  
  "data": {  
    "xyplat.adl_abnormal_app_overview_xyplat": [],  
    "nxyzs.app_cold": [],  
    "xydb.xyzs_app_xyapplist_xydb": [],  
    "data_mining.bdl_cnxy_biguser_login_days": [],  
    "data_mining.adl_cnxy_profileshow_payavg": []  
  }  
} 

hintOptions的tables属性是一个object,key是表名,value是一个数组,数组里面是这个表对应的所有列名。我这里没有取表的列,所以返回了一个空数组,只在输入表名的时候会智能提示。

 

以上都是拿来就能用的东西,不需要改动codemirror本身代码。

由于我使用了一些时间模板变量,我也希望能加到智能提示当中去,于是需要去定制改动一下sql-hint插件:

// CodeMirror, copyright (c) by Marijn Haverbeke and others  
// Distributed under an MIT license: http://codemirror.net/LICENSE  
  
(function(mod) {  
  if (typeof exports == "object" && typeof module == "object") // CommonJS  
    mod(require("../../lib/codemirror"), require("../../mode/sql/sql"));  
  else if (typeof define == "function" && define.amd) // AMD  
    define(["../../lib/codemirror", "../../mode/sql/sql"], mod);  
  else // Plain browser env  
    mod(CodeMirror);  
})(function(CodeMirror) {  
  "use strict";  
  
  var dtTemplates;//定义一个数组用来存放时间模板变量  
  var tables;  
  var defaultTable;  
  var keywords;  
  var identifierQuote;  
  var CONS = {  
    QUERY_DIV: ";",  
    ALIAS_KEYWORD: "AS"  
  };  
  var Pos = CodeMirror.Pos, cmpPos = CodeMirror.cmpPos;  
  
  function isArray(val) { return Object.prototype.toString.call(val) == "[object Array]" }  
  
  //创建所有时间模板变量  
  function getDtTemplates() {  
        var s = new Array();  
        s.push("${dt}");  
        s.push("${cdt}");  
        s.push("${wfd}");  
        s.push("${wld}");  
        s.push("${mfd}");  
        s.push("${mld}");  
        for (var i=1;i<=99;i++)  
        {  
            s.push("${dt"+i+"}");  
            s.push("${dt_"+i+"}");  
            s.push("${cdt"+i+"}");  
            s.push("${cdt_"+i+"}");  
        }  
        for (var i=1;i<=12;i++)  
        {  
            s.push("${dt"+i+"m}");  
            s.push("${dt_"+i+"m}");  
            s.push("${cdt"+i+"m}");  
            s.push("${cdt_"+i+"m}");  
        }  
        return s;  
  }  
  
  function getKeywords(editor) {  
    var mode = editor.doc.modeOption;  
    if (mode === "sql") mode = "text/x-sql";  
    return CodeMirror.resolveMode(mode).keywords;  
  }  
  
  function getIdentifierQuote(editor) {  
    var mode = editor.doc.modeOption;  
    if (mode === "sql") mode = "text/x-sql";  
    return CodeMirror.resolveMode(mode).identifierQuote || "`";  
  }  
  
  function getText(item) {  
    return typeof item == "string" ? item : item.text;  
  }  
  
  function wrapTable(name, value) {  
    if (isArray(value)) value = {columns: value}  
    if (!value.text) value.text = name  
    return value  
  }  
  
  function parseTables(input) {  
    var result = {}  
    if (isArray(input)) {  
      for (var i = input.length - 1; i >= 0; i--) {  
        var item = input[i]  
        result[getText(item).toUpperCase()] = wrapTable(getText(item), item)  
      }  
    } else if (input) {  
      for (var name in input)  
        result[name.toUpperCase()] = wrapTable(name, input[name])  
    }  
    return result  
  }  
  
  function getTable(name) {  
    return tables[name.toUpperCase()]  
  }  
  
  function shallowClone(object) {  
    var result = {};  
    for (var key in object) if (object.hasOwnProperty(key))  
      result[key] = object[key];  
    return result;  
  }  
  
  function match(string, word) {  
    var len = string.length;  
    var sub = getText(word).substr(0, len);  
    return string.toUpperCase() === sub.toUpperCase();  
  }  
  
  function addMatches(result, search, wordlist, formatter) {  
    if (isArray(wordlist)) {  
      for (var i = 0; i < wordlist.length; i++)  
        if (match(search, wordlist[i])) result.push(formatter(wordlist[i]))  
    } else {  
      for (var word in wordlist) if (wordlist.hasOwnProperty(word)) {  
        var val = wordlist[word]  
        if (!val || val === true)  
          val = word  
        else  
          val = val.displayText ? {text: val.text, displayText: val.displayText} : val.text  
        if (match(search, val)) result.push(formatter(val))  
      }  
    }  
  }  
  
  function cleanName(name) {  
    // Get rid name from identifierQuote and preceding dot(.)  
    if (name.charAt(0) == ".") {  
      name = name.substr(1);  
    }  
    // replace doublicated identifierQuotes with single identifierQuotes  
    // and remove single identifierQuotes  
    var nameParts = name.split(identifierQuote+identifierQuote);  
    for (var i = 0; i < nameParts.length; i++)  
      nameParts[i] = nameParts[i].replace(new RegExp(identifierQuote,"g"), "");  
    return nameParts.join(identifierQuote);  
  }  
  
  function insertIdentifierQuotes(name) {  
    var nameParts = getText(name).split(".");  
    for (var i = 0; i < nameParts.length; i++)  
      nameParts[i] = identifierQuote +  
        // doublicate identifierQuotes  
        nameParts[i].replace(new RegExp(identifierQuote,"g"), identifierQuote+identifierQuote) +  
        identifierQuote;  
    var escaped = nameParts.join(".");  
    if (typeof name == "string") return escaped;  
    name = shallowClone(name);  
    name.text = escaped;  
    return name;  
  }  
  
  function nameCompletion(cur, token, result, editor) {  
    // Try to complete table, column names and return start position of completion  
    var useIdentifierQuotes = false;  
    var nameParts = [];  
    var start = token.start;  
    var cont = true;  
    while (cont) {  
      cont = (token.string.charAt(0) == ".");  
      useIdentifierQuotes = useIdentifierQuotes || (token.string.charAt(0) == identifierQuote);  
  
      start = token.start;  
      nameParts.unshift(cleanName(token.string));  
  
      token = editor.getTokenAt(Pos(cur.line, token.start));  
      if (token.string == ".") {  
        cont = true;  
        token = editor.getTokenAt(Pos(cur.line, token.start));  
      }  
    }  
  
    // Try to complete table names  
    var string = nameParts.join(".");  
    addMatches(result, string, tables, function(w) {  
      return useIdentifierQuotes ? insertIdentifierQuotes(w) : w;  
    });  
  
    // Try to complete columns from defaultTable  
    addMatches(result, string, defaultTable, function(w) {  
      return useIdentifierQuotes ? insertIdentifierQuotes(w) : w;  
    });  
  
    // Try to complete columns  
    string = nameParts.pop();  
    var table = nameParts.join(".");  
  
    var alias = false;  
    var aliasTable = table;  
    // Check if table is available. If not, find table by Alias  
    if (!getTable(table)) {  
      var oldTable = table;  
      table = findTableByAlias(table, editor);  
      if (table !== oldTable) alias = true;  
    }  
  
    var columns = getTable(table);  
    if (columns && columns.columns)  
      columns = columns.columns;  
  
    if (columns) {  
      addMatches(result, string, columns, function(w) {  
        var tableInsert = table;  
        if (alias == true) tableInsert = aliasTable;  
        if (typeof w == "string") {  
          w = tableInsert + "." + w;  
        } else {  
          w = shallowClone(w);  
          w.text = tableInsert + "." + w.text;  
        }  
        return useIdentifierQuotes ? insertIdentifierQuotes(w) : w;  
      });  
    }  
  
    return start;  
  }  
  
  function eachWord(lineText, f) {  
    if (!lineText) return;  
    var excepted = /[,;]/g;  
    var words = lineText.split(" ");  
    for (var i = 0; i < words.length; i++) {  
      f(words[i]?words[i].replace(excepted, \'\') : \'\');  
    }  
  }  
  
  function findTableByAlias(alias, editor) {  
    var doc = editor.doc;  
    var fullQuery = doc.getValue();  
    var aliasUpperCase = alias.toUpperCase();  
    var previousWord = "";  
    var table = "";  
    var separator = [];  
    var validRange = {  
      start: Pos(0, 0),  
      end: Pos(editor.lastLine(), editor.getLineHandle(editor.lastLine()).length)  
    };  
  
    //add separator  
    var indexOfSeparator = fullQuery.indexOf(CONS.QUERY_DIV);  
    while(indexOfSeparator != -1) {  
      separator.push(doc.posFromIndex(indexOfSeparator));  
      indexOfSeparator = fullQuery.indexOf(CONS.QUERY_DIV, indexOfSeparator+1);  
    }  
    separator.unshift(Pos(0, 0));  
    separator.push(Pos(editor.lastLine(), editor.getLineHandle(editor.lastLine()).text.length));  
  
    //find valid range  
    var prevItem = null;  
    var current = editor.getCursor();  
    for (var i = 0; i < separator.length; i++) {  
      if ((prevItem == null || cmpPos(current, prevItem) > 0) && cmpPos(current, separator[i]) <= 0) {  
        validRange = {start: prevItem, end: separator[i]};  
        break;  
      }  
      prevItem = separator[i];  
    }  
  
    var query = doc.getRange(validRange.start, validRange.end, false);  
  
    for (var i = 0; i < query.length; i++) {  
      var lineText = query[i];  
      eachWord(lineText, function(word) {  
        var wordUpperCase = word.toUpperCase();  
        if (wordUpperCase === aliasUpperCase && getTable(previousWord))  
          table = previousWord;  
        if (wordUpperCase !== CONS.ALIAS_KEYWORD)  
          previousWord = word;  
      });  
      if (table) break;  
    }  
    return table;  
  }  
  
  CodeMirror.registerHelper("hint", "sql", function(editor, options) {  
    //创建所有日期模板变量  
    dtTemplates =  getDtTemplates() ;  
    tables = parseTables(options && options.tables)  
    var defaultTableName = options && options.defaultTable;  
    var disableKeywords = options && options.disableKeywords;  
    defaultTable = defaultTableName && getTable(defaultTableName);  
    keywords = getKeywords(editor);  
    identifierQuote = getIdentifierQuote(editor);  
  
    if (defaultTableName && !defaultTable)  
      defaultTable = findTableByAlias(defaultTableName, editor);  
  
    defaultTable = defaultTable || [];  
  
    if (defaultTable.columns)  
      defaultTable = defaultTable.columns;  
  
    var cur = editor.getCursor();  
    var result = [];  
    var token = editor.getTokenAt(cur), start, end, search;  
      
    if (token.end > cur.ch) {  
      token.end = cur.ch;  
      token.string = token.string.slice(0, cur.ch - token.start);  
    }  
    //将$和{也加入到自动完成规则中来  
    if (token.string.match(/^[${.`"\\w@]\\w*$/)) {  
      search = token.string;  
      start = token.start;  
      end = token.end;  
    } else {  
      start = end = cur.ch;  
      search = "";  
    }  
    if (search.charAt(0) == "." || search.charAt(0) == identifierQuote) {  
      start = nameCompletion(cur, token, result, editor);  
    }   
    else if (search.charAt(0) == "$") {  
      addMatches(result, search, dtTemplates, function(w) {return w;});  
    }   
    else if (search.charAt(0) == "{") {  
        //如果当前token是以\'{\'开头,那么判断一下前一个token是不是\'$\',如果是的话,将搜索字符串变成以\'${\'开头的字符串去日期模板中匹配自动完成  
        token = editor.getTokenAt(Pos(cur.line, token.start));  
        if(token.string == "$")  
        {  
            search = token.string + search;  
            start = token.start;  
      }  
      addMatches(result, search, dtTemplates, function(w) {return w;});  
    }   
    else {  
      addMatches(result, search, tables, function(w) {return w;});  
      addMatches(result, search, defaultTable, function(w) {return w;});  
      if (!disableKeywords)  
        addMatches(result, search, keywords, function(w) {return w.toUpperCase();});  
    }  
  
    return {list: result, from: Pos(cur.line, start), to: Pos(cur.line, end)};  
  });  
});

加了中文注释部分就是我加的一些代码,不一定很严谨,至少实现了功能,当输入token以$或者${开头的时候的都会智能提示时间模板变量,效果如下图:

 

当输入表名前缀的时候会智能提示相应匹配的表名:

 

 

 

若想在一个页面上创建多个codemirror编辑框,则可以这样写:

<%@ page language="java" pageEncoding="utf-8" %>  
<!doctype html>  
  
<title>CodeMirror: SQL Mode for CodeMirror</title>  
<meta charset="utf-8"/>  
<script src="js/jquery-2.2.3.min.js"></script>  
<link rel="stylesheet" href="js/codemirror-5.25.0/lib/codemirror.css"/>  
<script src="js/codemirror-5.25.0/lib/codemirror.js"></script>  
<script src="js/codemirror-5.25.0/mode/sql/sql.js"></script>  
<link rel="stylesheet" href="js/codemirror-5.25.0/addon/hint/show-hint.css"/>  
<script src="js/codemirror-5.25.0/addon/hint/show-hint.js"></script>  
<script src="js/codemirror-5.25.0/addon/hint/sql-hint.js"></script>  
<script src="js/codemirror-5.25.0/addon/selection/active-line.js"></script>  
<style>  
    .CodeMirror {  
        border-top: 1px solid black;  
        border-bottom: 1px solid black;  
    }  
</style>  
<input type="button" value="获取内容" onclick="getAllSqls()"/>  
<article>  
    <h2>SQL Mode for CodeMirror</h2>  
  
    <form id="cm_form">  
  
    </form>  
    <script>  
        window.onload = function () {  
            $.getJSON("job/schema/1", {}, function (result) {  
                var mime = \'text/x-hive\';  
                for (var i = 1; i <= 2; i++) {  
                    for (var j = 1; j <= 2; j++) {  
                        var textarea = doc

以上是关于用codemirror实现一个自己的简单hive ql编辑器的主要内容,如果未能解决你的问题,请参考以下文章

在线代码编辑器CodeMirror简介

在vue里使用codemirror的两种用法

vue(element)中使用codemirror实现代码高亮,代码补全,版本差异对比

vue(element)中使用codemirror实现代码高亮,代码补全,版本差异对比

CodeMirror---实现关键词高亮

实用的工具地址收藏