SQLONMongoDB实现原理

1. 概述

创新互联专注于丰润企业网站建设,响应式网站开发,成都商城网站开发。丰润网站建设公司,为丰润等地区提供建站服务。全流程按需制作，专业设计，全程项目跟踪，创新互联专业和态度为您提供的服务

可能你在看到这个标题会小小的吃惊，MyCAT 能使用 MongoDB 做数据节点。是的，没错，确实可以。

吼吼吼，让我们开启这段神奇的“旅途”。

本文主要分成四部分：

  1. 总体流程，让你有个整体的认识
  2. 查询操作
  3. 插入操作
  4. 彩蛋，彩蛋，彩蛋

建议你看过这两篇文章(_非必须_)：

  1. 《MyCAT源码分析 —— 【单库单表】插入》
  2. 《MyCAT源码分析 —— 【单库单表】查询》

2. 主流程

  1. MyCAT Server 接收 MySQL Client 基于 MySQL协议 的请求，翻译 SQL 成 MongoDB操作 发送给 MongoDB Server。
  2. MyCAT Server 接收 MongoDB Server 返回的 MongoDB数据，翻译成 MySQL数据结果 返回给 MySQL Client。

这样一看，MyCAT 连接 MongoDB 是不是少神奇一点列。

Java数据库连接，(Java Database Connectivity，简称JDBC)是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。JDBC是面向关系型数据库的。

MyCAT 使用 JDBC 规范，抽象了对 MongoDB 的访问。通过这样的方式，MyCAT 也抽象了 SequoiaDB 的访问。可能这样说法有些抽象，看个类图压压惊。

是不是熟悉的味道。不得不说 JDBC 规范的精妙。

3. 查询操作

 
 
 
 
    
  
  
  
  
  1. SELECT id, name FROM user WHERE name > '' ORDER BY _id DESC;  
    2.

看顺序图已经很方便的理解整体逻辑，我就不多废话啦。我们来看几个核心的代码逻辑。

1)、查询 MongoDB

 
 
 
 
    
  
  
  
  
  1. // MongoSQLParser.java 
    2.   
  
  
  
  2. public MongoData query() throws MongoSQLException { 
    3.   
  
  
  
  3.    if (!(statement instanceof SQLSelectStatement)) { 
    4.   
  
  
  
  4.        //return null; 
    5.   
  
  
  
  5.        throw new IllegalArgumentException("not a query sql statement"); 
    6.   
  
  
  
  6.    } 
    7.   
  
  
  
  7.    MongoData mongo = new MongoData(); 
    8.   
  
  
  
  8.    DBCursor c = null; 
    9.   
  
  
  
  9.    SQLSelectStatement selectStmt = (SQLSelectStatement) statement; 
    10.   
  
  
  
  10.    SQLSelectQuery sqlSelectQuery = selectStmt.getSelect().getQuery(); 
    11.   
  
  
  
  11.    int icount = 0; 
    12.   
  
  
  
  12.    if (sqlSelectQuery instanceof MySqlSelectQueryBlock) { 
    13.   
  
  
  
  13.        MySqlSelectQueryBlock mysqlSelectQuery = (MySqlSelectQueryBlock) selectStmt.getSelect().getQuery(); 
    14.   
  
  
  
  14.  
    15.   
  
  
  
  15.        BasicDBObject fields = new BasicDBObject(); 
    16.   
  
  
  
  16.  
    17.   
  
  
  
  17.        // 显示（返回）的字段 
    18.   
  
  
  
  18.        for (SQLSelectItem item : mysqlSelectQuery.getSelectList()) { 
    19.   
  
  
  
  19.            //System.out.println(item.toString()); 
    20.   
  
  
  
  20.            if (!(item.getExpr() instanceof SQLAllColumnExpr)) { 
    21.   
  
  
  
  21.                if (item.getExpr() instanceof SQLAggregateExpr) { 
    22.   
  
  
  
  22.                    SQLAggregateExpr expr = (SQLAggregateExpr) item.getExpr(); 
    23.   
  
  
  
  23.                    if (expr.getMethodName().equals("COUNT")) { // TODO 待读：count（*） 
    24.   
  
  
  
  24.                        icount = 1; 
    25.   
  
  
  
  25.                        mongo.setField(getExprFieldName(expr), Types.BIGINT); 
    26.   
  
  
  
  26.                    } 
    27.   
  
  
  
  27.                    fields.put(getExprFieldName(expr), 1); 
    28.   
  
  
  
  28.                } else { 
    29.   
  
  
  
  29.                    fields.put(getFieldName(item), 1); 
    30.   
  
  
  
  30.                } 
    31.   
  
  
  
  31.            } 
    32.   
  
  
  
  32.  
    33.   
  
  
  
  33.        } 
    34.   
  
  
  
  34.  
    35.   
  
  
  
  35.        // 表名 
    36.   
  
  
  
  36.        SQLTableSource table = mysqlSelectQuery.getFrom(); 
    37.   
  
  
  
  37.        DBCollection coll = this._db.getCollection(table.toString()); 
    38.   
  
  
  
  38.        mongo.setTable(table.toString()); 
    39.   
  
  
  
  39.  
    40.   
  
  
  
  40.        // WHERE 
    41.   
  
  
  
  41.        SQLExpr expr = mysqlSelectQuery.getWhere(); 
    42.   
  
  
  
  42.        DBObject query = parserWhere(expr); 
    43.   
  
  
  
  43.  
    44.   
  
  
  
  44.        // GROUP BY 
    45.   
  
  
  
  45.        SQLSelectGroupByClause groupby = mysqlSelectQuery.getGroupBy(); 
    46.   
  
  
  
  46.        BasicDBObject gbkey = new BasicDBObject(); 
    47.   
  
  
  
  47.        if (groupby != null) { 
    48.   
  
  
  
  48.            for (SQLExpr gbexpr : groupby.getItems()) { 
    49.   
  
  
  
  49.                if (gbexpr instanceof SQLIdentifierExpr) { 
    50.   
  
  
  
  50.                    String name = ((SQLIdentifierExpr) gbexpr).getName(); 
    51.   
  
  
  
  51.                    gbkey.put(name, Integer.valueOf(1)); 
    52.   
  
  
  
  52.                } 
    53.   
  
  
  
  53.            } 
    54.   
  
  
  
  54.            icount = 2; 
    55.   
  
  
  
  55.        } 
    56.   
  
  
  
  56.  
    57.   
  
  
  
  57.        // SKIP / LIMIT 
    58.   
  
  
  
  58.        int limitoff = 0; 
    59.   
  
  
  
  59.        int limitnum = 0; 
    60.   
  
  
  
  60.        if (mysqlSelectQuery.getLimit() != null) { 
    61.   
  
  
  
  61.            limitoff = getSQLExprToInt(mysqlSelectQuery.getLimit().getOffset()); 
    62.   
  
  
  
  62.            limitnum = getSQLExprToInt(mysqlSelectQuery.getLimit().getRowCount()); 
    63.   
  
  
  
  63.        } 
    64.   
  
  
  
  64.        if (icount == 1) { // COUNT（*） 
    65.   
  
  
  
  65.            mongo.setCount(coll.count(query)); 
    66.   
  
  
  
  66.        } else if (icount == 2) { // MapReduce 
    67.   
  
  
  
  67.            BasicDBObject initial = new BasicDBObject(); 
    68.   
  
  
  
  68.            initial.put("num", 0); 
    69.   
  
  
  
  69.            String reduce = "function (obj, prev) { " + "  prev.num++}"; 
    70.   
  
  
  
  70.            mongo.setGrouyBy(coll.group(gbkey, query, initial, reduce)); 
    71.   
  
  
  
  71.        } else { 
    72.   
  
  
  
  72.            if ((limitoff > 0) || (limitnum > 0)) { 
    73.   
  
  
  
  73.                c = coll.find(query, fields).skip(limitoff).limit(limitnum); 
    74.   
  
  
  
  74.            } else { 
    75.   
  
  
  
  75.                c = coll.find(query, fields); 
    76.   
  
  
  
  76.            } 
    77.   
  
  
  
  77.  
    78.   
  
  
  
  78.            // order by 
    79.   
  
  
  
  79.            SQLOrderBy orderby = mysqlSelectQuery.getOrderBy(); 
    80.   
  
  
  
  80.            if (orderby != null) { 
    81.   
  
  
  
  81.                BasicDBObject order = new BasicDBObject(); 
    82.   
  
  
  
  82.                for (int i = 0; i < orderby.getItems().size(); i++) { 
    83.   
  
  
  
  83.                    SQLSelectOrderByItem orderitem = orderby.getItems().get(i); 
    84.   
  
  
  
  84.                    order.put(orderitem.getExpr().toString(), getSQLExprToAsc(orderitem.getType())); 
    85.   
  
  
  
  85.                } 
    86.   
  
  
  
  86.                c.sort(order); 
    87.   
  
  
  
  87.                // System.out.println(order); 
    88.   
  
  
  
  88.            } 
    89.   
  
  
  
  89.        } 
    90.   
  
  
  
  90.        mongo.setCursor(c); 
    91.   
  
  
  
  91.    } 
    92.   
  
  
  
  92.    return mongo; 
    93.   
  
  
  
  93. }  
    94.

2)、查询条件

 
 
 
 
    
  
  
  
  
  1. // MongoSQLParser.java 
    2.   
  
  
  
  2. private void parserWhere(SQLExpr aexpr, BasicDBObject o) { 
    3.   
  
  
  
  3.    if (aexpr instanceof SQLBinaryOpExpr) { 
    4.   
  
  
  
  4.        SQLBinaryOpExpr expr = (SQLBinaryOpExpr) aexpr; 
    5.   
  
  
  
  5.        SQLExpr exprL = expr.getLeft(); 
    6.   
  
  
  
  6.        if (!(exprL instanceof SQLBinaryOpExpr)) { 
    7.   
  
  
  
  7.            if (expr.getOperator().getName().equals("=")) { 
    8.   
  
  
  
  8.                o.put(exprL.toString(), getExpValue(expr.getRight())); 
    9.   
  
  
  
  9.            } else { 
    10.   
  
  
  
  10.                String op = ""; 
    11.   
  
  
  
  11.                if (expr.getOperator().getName().equals("<")) { 
    12.   
  
  
  
  12.                    op = "$lt"; 
    13.   
  
  
  
  13.                } else if (expr.getOperator().getName().equals("<=")) { 
    14.   
  
  
  
  14.                    op = "$lte"; 
    15.   
  
  
  
  15.                } else if (expr.getOperator().getName().equals(">")) { 
    16.   
  
  
  
  16.                    op = "$gt"; 
    17.   
  
  
  
  17.                } else if (expr.getOperator().getName().equals(">=")) { 
    18.   
  
  
  
  18.                    op = "$gte"; 
    19.   
  
  
  
  19.                } else if (expr.getOperator().getName().equals("!=")) { 
    20.   
  
  
  
  20.                    op = "$ne"; 
    21.   
  
  
  
  21.                } else if (expr.getOperator().getName().equals("<>")) { 
    22.   
  
  
  
  22.                    op = "$ne"; 
    23.   
  
  
  
  23.                } 
    24.   
  
  
  
  24.                parserDBObject(o, exprL.toString(), op, getExpValue(expr.getRight())); 
    25.   
  
  
  
  25.            } 
    26.   
  
  
  
  26.        } else { 
    27.   
  
  
  
  27.            if (expr.getOperator().getName().equals("AND")) { 
    28.   
  
  
  
  28.                parserWhere(exprL, o); 
    29.   
  
  
  
  29.                parserWhere(expr.getRight(), o); 
    30.   
  
  
  
  30.            } else if (expr.getOperator().getName().equals("OR")) { 
    31.   
  
  
  
  31.                orWhere(exprL, expr.getRight(), o); 
    32.   
  
  
  
  32.            } else { 
    33.   
  
  
  
  33.                throw new RuntimeException("Can't identify the operation of  of where"); 
    34.   
  
  
  
  34.            } 
    35.   
  
  
  
  35.        } 
    36.   
  
  
  
  36.    } 
    37.   
  
  
  
  37. } 
    38.   
  
  
  
  38.  
    39.   
  
  
  
  39. private void orWhere(SQLExpr exprL, SQLExpr exprR, BasicDBObject ob) { 
    40.   
  
  
  
  40.    BasicDBObject xo = new BasicDBObject(); 
    41.   
  
  
  
  41.    BasicDBObject yo = new BasicDBObject(); 
    42.   
  
  
  
  42.    parserWhere(exprL, xo); 
    43.   
  
  
  
  43.    parserWhere(exprR, yo); 
    44.   
  
  
  
  44.    ob.put("$or", new Object[]{xo, yo}); 
    45.   
  
  
  
  45. }  
    46.

3)、解析 MongoDB 数据

 
 
 
 
    
  
  
  
  
  1. // MongoResultSet.java 
    2.   
  
  
  
  2. public MongoResultSet(MongoData mongo, String schema) throws SQLException { 
    3.   
  
  
  
  3.    this._cursor = mongo.getCursor(); 
    4.   
  
  
  
  4.    this._schema = schema; 
    5.   
  
  
  
  5.    this._table = mongo.getTable(); 
    6.   
  
  
  
  6.    this.isSum = mongo.getCount() > 0; 
    7.   
  
  
  
  7.    this._sum = mongo.getCount(); 
    8.   
  
  
  
  8.    this.isGroupBy = mongo.getType(); 
    9.   
  
  
  
  9.  
    10.   
  
  
  
  10.    if (this.isGroupBy) { 
    11.   
  
  
  
  11.        dblist = mongo.getGrouyBys(); 
    12.   
  
  
  
  12.        this.isSum = true; 
    13.   
  
  
  
  13.    } 
    14.   
  
  
  
  14.    if (this._cursor != null) { 
    15.   
  
  
  
  15.        select = _cursor.getKeysWanted().keySet().toArray(new String[0]); 
    16.   
  
  
  
  16.        // 解析 fields 
    17.   
  
  
  
  17.        if (this._cursor.hasNext()) { 
    18.   
  
  
  
  18.            _cur = _cursor.next(); 
    19.   
  
  
  
  19.            if (_cur != null) { 
    20.   
  
  
  
  20.                if (select.length == 0) { 
    21.   
  
  
  
  21.                    SetFields(_cur.keySet()); 
    22.   
  
  
  
  22.                } 
    23.   
  
  
  
  23.                _row = 1; 
    24.   
  
  
  
  24.            } 
    25.   
  
  
  
  25.        } 
    26.   
  
  
  
  26.        // 设置 fields 类型 
    27.   
  
  
  
  27.        if (select.length == 0) { 
    28.   
  
  
  
  28.            select = new String[]{"_id"}; 
    29.   
  
  
  
  29.            SetFieldType(true); 
    30.   
  
  
  
  30.        } else { 
    31.   
  
  
  
  31.            SetFieldType(false); 
    32.   
  
  
  
  32.        } 
    33.   
  
  
  
  33.    } else { 
    34.   
  
  
  
  34.        SetFields(mongo.getFields().keySet());//new String[]{"COUNT(*)"}; 
    35.   
  
  
  
  35.        SetFieldType(mongo.getFields()); 
    36.   
  
  
  
  36.    } 
    37.   
  
  
  
  37. }  
    38.

当使用 SELECT * 查询字段时，fields 使用***条数据返回的 fields。即使，后面的数据有其他 fields，也不返回。

4)、返回数据给 MySQL Client

 
 
 
 
    
  
  
  
  
  1. // JDBCConnection.java 
    2.   
  
  
  
  2. private void ouputResultSet(ServerConnection sc, String sql) 
    3.   
  
  
  
  3.        throws SQLException { 
    4.   
  
  
  
  4.    ResultSet rs = null; 
    5.   
  
  
  
  5.    Statement stmt = null; 
    6.   
  
  
  
  6.  
    7.   
  
  
  
  7.    try { 
    8.   
  
  
  
  8.        stmt = con.createStatement(); 
    9.   
  
  
  
  9.        rs = stmt.executeQuery(sql); 
    10.   
  
  
  
  10.  
    11.   
  
  
  
  11.        // header 
    12.   
  
  
  
  12.        List fieldPks = new LinkedList<>(); 
    13.   
  
  
  
  13.        ResultSetUtil.resultSetToFieldPacket(sc.getCharset(), fieldPks, rs, this.isSpark); 
    14.   
  
  
  
  14.        int colunmCount = fieldPks.size(); 
    15.   
  
  
  
  15.        ByteBuffer byteBuf = sc.allocate(); 
    16.   
  
  
  
  16.        ResultSetHeaderPacket headerPkg = new ResultSetHeaderPacket(); 
    17.   
  
  
  
  17.        headerPkg.fieldCount = fieldPks.size(); 
    18.   
  
  
  
  18.        headerPkg.packetId = ++packetId; 
    19.   
  
  
  
  19.        byteBuf = headerPkg.write(byteBuf, sc, true); 
    20.   
  
  
  
  20.        byteBuf.flip(); 
    21.   
  
  
  
  21.        byte[] header = new byte[byteBuf.limit()]; 
    22.   
  
  
  
  22.        byteBuf.get(header); 
    23.   
  
  
  
  23.        byteBuf.clear(); 
    24.   
  
  
  
  24.        List fields = new ArrayList(fieldPks.size()); 
    25.   
  
  
  
  25.        for (FieldPacket curField : fieldPks) { 
    26.   
  
  
  
  26.            curField.packetId = ++packetId; 
    27.   
  
  
  
  27.            byteBuf = curField.write(byteBuf, sc, false); 
    28.   
  
  
  
  28.            byteBuf.flip(); 
    29.   
  
  
  
  29.            byte[] field = new byte[byteBuf.limit()]; 
    30.   
  
  
  
  30.            byteBuf.get(field); 
    31.   
  
  
  
  31.            byteBuf.clear(); 
    32.   
  
  
  
  32.            fields.add(field); 
    33.   
  
  
  
  33.        } 
    34.   
  
  
  
  34.        // header eof 
    35.   
  
  
  
  35.        EOFPacket eofPckg = new EOFPacket(); 
    36.   
  
  
  
  36.        eofPckg.packetId = ++packetId; 
    37.   
  
  
  
  37.        byteBuf = eofPckg.write(byteBuf, sc, false); 
    38.   
  
  
  
  38.        byteBuf.flip(); 
    39.   
  
  
  
  39.        byte[] eof = new byte[byteBuf.limit()]; 
    40.   
  
  
  
  40.        byteBuf.get(eof); 
    41.   
  
  
  
  41.        byteBuf.clear(); 
    42.   
  
  
  
  42.        this.respHandler.fieldEofResponse(header, fields, eof, this); 
    43.   
  
  
  
  43.  
    44.   
  
  
  
  44.        // row 
    45.   
  
  
  
  45.        while (rs.next()) { 
    46.   
  
  
  
  46.            RowDataPacket curRow = new RowDataPacket(colunmCount); 
    47.   
  
  
  
  47.            for (int i = 0; i < colunmCount; i++) { 
    48.   
  
  
  
  48.                int j = i + 1; 
    49.   
  
  
  
  49.                if (MysqlDefs.isBianry((byte) fieldPks.get(i).type)) { 
    50.   
  
  
  
  50.                    curRow.add(rs.getBytes(j)); 
    51.   
  
  
  
  51.                } else if (fieldPks.get(i).type == MysqlDefs.FIELD_TYPE_DECIMAL || 
    52.   
  
  
  
  52.                        fieldPks.get(i).type == (MysqlDefs.FIELD_TYPE_NEW_DECIMAL - 256)) { // field type is unsigned byte 
    53.   
  
  
  
  53.                    // ensure that do not use scientific notation format 
    54.   
  
  
  
  54.                    BigDecimal val = rs.getBigDecimal(j); 
    55.   
  
  
  
  55.                    curRow.add(StringUtil.encode(val != null ? val.toPlainString() : null, sc.getCharset())); 
    56.   
  
  
  
  56.                } else { 
    57.   
  
  
  
  57.                    curRow.add(StringUtil.encode(rs.getString(j), sc.getCharset())); 
    58.   
  
  
  
  58.                } 
    59.   
  
  
  
  59.            } 
    60.   
  
  
  
  60.            curRow.packetId = ++packetId; 
    61.   
  
  
  
  61.            byteBuf = curRow.write(byteBuf, sc, false); 
    62.   
  
  
  
  62.            byteBuf.flip(); 
    63.   
  
  
  
  63.            byte[] row = new byte[byteBuf.limit()]; 
    64.   
  
  
  
  64.            byteBuf.get(row); 
    65.   
  
  
  
  65.            byteBuf.clear(); 
    66.   
  
  
  
  66.            this.respHandler.rowResponse(row, this); 
    67.   
  
  
  
  67.        } 
    68.   
  
  
  
  68.        fieldPks.clear(); 
    69.   
  
  
  
  69.        // row eof 
    70.   
  
  
  
  70.        eofPckg = new EOFPacket(); 
    71.   
  
  
  
  71.        eofPckg.packetId = ++packetId; 
    72.   
  
  
  
  72.        byteBuf = eofPckg.write(byteBuf, sc, false); 
    73.   
  
  
  
  73.        byteBuf.flip(); 
    74.   
  
  
  
  74.        eof = new byte[byteBuf.limit()]; 
    75.   
  
  
  
  75.        byteBuf.get(eof); 
    76.   
  
  
  
  76.        sc.recycle(byteBuf); 
    77.   
  
  
  
  77.        this.respHandler.rowEofResponse(eof, this); 
    78.   
  
  
  
  78.    } finally { 
    79.   
  
  
  
  79.        if (rs != null) { 
    80.   
  
  
  
  80.            try { 
    81.   
  
  
  
  81.                rs.close(); 
    82.   
  
  
  
  82.            } catch (SQLException e) { 
    83.   
  
  
  
  83.            } 
    84.   
  
  
  
  84.        } 
    85.   
  
  
  
  85.        if (stmt != null) { 
    86.   
  
  
  
  86.            try { 
    87.   
  
  
  
  87.                stmt.close(); 
    88.   
  
  
  
  88.            } catch (SQLException e) { 
    89.   
  
  
  
  89.            } 
    90.   
  
  
  
  90.        } 
    91.   
  
  
  
  91.    } 
    92.   
  
  
  
  92. } 
    93.   
  
  
  
  93.  
    94.   
  
  
  
  94. // MongoResultSet.java 
    95.   
  
  
  
  95. @Override 
    96.   
  
  
  
  96. public String getString(String columnLabel) throws SQLException { 
    97.   
  
  
  
  97.    Object x = getObject(columnLabel); 
    98.   
  
  
  
  98.    if (x == null) { 
    99.   
  
  
  
  99.        return null; 
    100.   
  
  
  
  100.    } 
    101.   
  
  
  
  101.    return x.toString(); 
    102.   
  
  
  
  102. }  
    103.

当返回字段值是 Object 时，返回该对象.toString()。例如：

 
 
 
 
    
  
  
  
  
  1. mysql> select * from user order by _id asc; 
    2.   
  
  
  
  2.  
    3.   
  
  
  
  3. +--------------------------+------+-------------------------------+ 
    4.   
  
  
  
  4.  
    5.   
  
  
  
  5. | _id | name | profile | 
    6.   
  
  
  
  6.  
    7.   
  
  
  
  7. +--------------------------+------+-------------------------------+ 
    8.   
  
  
  
  8.  
    9.   
  
  
  
  9. | 1 | 123 | { "age" : 1 , "height" : 100} |  
    10.

4. 插入操作

 
 
 
 
    
  
  
  
  
  1. // MongoSQLParser.java 
    2.   
  
  
  
  2. public int executeUpdate() throws MongoSQLException { 
    3.   
  
  
  
  3.    if (statement instanceof SQLInsertStatement) { 
    4.   
  
  
  
  4.        return InsertData((SQLInsertStatement) statement); 
    5.   
  
  
  
  5.    } 
    6.   
  
  
  
  6.    if (statement instanceof SQLUpdateStatement) { 
    7.   
  
  
  
  7.        return UpData((SQLUpdateStatement) statement); 
    8.   
  
  
  
  8.    } 
    9.   
  
  
  
  9.    if (statement instanceof SQLDropTableStatement) { 
    10.   
  
  
  
  10.        return dropTable((SQLDropTableStatement) statement); 
    11.   
  
  
  
  11.    } 
    12.   
  
  
  
  12.    if (statement instanceof SQLDeleteStatement) { 
    13.   
  
  
  
  13.        return DeleteDate((SQLDeleteStatement) statement); 
    14.   
  
  
  
  14.    } 
    15.   
  
  
  
  15.    if (statement instanceof SQLCreateTableStatement) { 
    16.   
  
  
  
  16.        return 1; 
    17.   
  
  
  
  17.    } 
    18.   
  
  
  
  18.    return 1; 
    19.   
  
  
  
  19. } 
    20.   
  
  
  
  20.  
    21.   
  
  
  
  21. private int InsertData(SQLInsertStatement state) { 
    22.   
  
  
  
  22.    if (state.getValues().getValues().size() == 0) { 
    23.   
  
  
  
  23.        throw new RuntimeException("number of  columns error"); 
    24.   
  
  
  
  24.    } 
    25.   
  
  
  
  25.    if (state.getValues().getValues().size() != state.getColumns().size()) { 
    26.   
  
  
  
  26.        throw new RuntimeException("number of values and columns have to match"); 
    27.   
  
  
  
  27.    } 
    28.   
  
  
  
  28.    SQLTableSource table = state.getTableSource(); 
    29.   
  
  
  
  29.    BasicDBObject o = new BasicDBObject(); 
    30.   
  
  
  
  30.    int i = 0; 
    31.   
  
  
  
  31.    for (SQLExpr col : state.getColumns()) { 
    32.   
  
  
  
  32.        o.put(getFieldName2(col), getExpValue(state.getValues().getValues().get(i))); 
    33.   
  
  
  
  33.        i++; 
    34.   
  
  
  
  34.    } 
    35.   
  
  
  
  35.    DBCollection coll = this._db.getCollection(table.toString()); 
    36.   
  
  
  
  36.    coll.insert(o); 
    37.   
  
  
  
  37.    return 1; 
    38.   
  
  
  
  38. }  
    39.

5. 彩蛋

1)、支持多 MongoDB ，并使用 MyCAT 进行分片。

MyCAT 配置：multi_mongodb

2)、支持 MongoDB + MySQL 作为同一个 MyCAT Table 的数据节点。查询时，可以合并数据结果。

查询时，返回 MySQL 数据记录字段要比 MongoDB 数据记录字段全，否则，合并结果时会报错。

MyCAT 配置：single_mongodb_mysql

3)、MongoDB 作为数据节点时，可以使用 MyCAT 提供的数据库主键字段功能。

MyCAT 配置：single_mongodb

文章题目：SQLONMongoDB实现原理
网页地址：http://www.shufengxianlan.com/qtweb/news21/10871.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

全网营销推广知识

分类信息网

眉山托管服务器　　 　成都外贸网站建设　　 　珉田数据中心　　 　成都响应式网站建设　　 　香港云主机　　 　成都小程序开发　　 　成都服务器托管　　 　成都网站制作　　 　成都网站建设公司　　 　成都网站建设公司　　 　自贡托管服务器　　 　成都艺考培训　　 　led无边发光字　　 　网络推广公司　　 　上海除甲醛　　 　简阳网站建设　　 　主动防护网　　 　企业网站维护　　 　成都婚庆策划　　 　成都app软件开发公司