  @Test
  public void sqlTableParserTest() throws Exception {

    String table = "CREATE TABLE tbl1 (\n" +
        "  `a` bigint,\n" +
        "  `date` date,\n" +
        "  h varchar, \n" +
        "  g as 2 * (a + 1), \n" +
        "  ts as toTimestamp(b, 'yyyy-MM-dd HH:mm:ss'), \n" +
        "  b varchar,\n" +
        "  proc as PROCTIME(), \n" +
        "  PRIMARY KEY (a, b)\n" +
        ")\n" +
        "with (\n" +
        "    'connector' = 'kafka', \n" +
        "    'kafka.topic' = 'log.test'\n" +
        ")\n";
    List<SqlCreateTable> list = service.sqlTableParser(table);
    Assert.assertEquals(list.size(), 1);
  }