规范Mongodb示例方法名称

ipu-mongodb-example/src/test/java/com/ai/ipu/example/mongodb/MongodbExample.java

  /**
   * 插入一条数据
   * @throws Exception
   */
  public void testExecuteInsert() throws Exception {
    JSONObject param = new JSONObject();
    param.put("name", "mongo");
    param.put("nikeName", "jack");
    param.put("ver", 7.0);
    param.put("age",21);
    param.put("info", "this is a test info");
    log.debug("before insert, num is :" + noSql.takeRecordNum(param.toJSONString()));
    noSql.executeInsert(param);
    log.debug("after insert, num is :" + noSql.takeRecordNum(param.toJSONString()));
  }
  /**
   * 插入一条数据
   *
   * @throws Exception
   */
  public void testExecuteInsert2() throws Exception {
  public void testExecuteInsert() throws Exception {
    JSONObject param = new JSONObject();
    param.put("name", "mongo");
    log.debug("before insert, num is :" + noSql.takeRecordNum(param.toJSONString()));
    log.debug("符合条件记录数:" + noSql.takeRecordNum(cond.toJSONString()));
  }
  /**
   * 查询符合条件的首记录(升序)
   * 查询collection里符合条件的所有记录
   *
   * @throws Exception
   */
  public void testExecuteSelectAll() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "tom");
    log.debug("符合条件记录数:" + noSql.executeSelect(cond.toJSONString()));
  }
  /**
   * 返回collection里符合条件的首记录(升序)
   * 参数{"_id":1}: 1:代表升序输出,-1代表降序输出
   * @throws Exception
   */
  public void testExecuteSelectOne() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "miaozy");
    cond.put("nickName", "tom");
    log.debug("查询结果为:" + noSql.executeSelectOne(cond.toJSONString(), "{\"_id\":1}"));
  }
  /**
   * 查询符合条件的首记录(返回指定字段)
   *
   * 指定返回字段,查询collection里符合条件的首记录
   * 参数{"_id":1}: 1:代表升序输出,-1代表降序输出
   * @throws Exception
   */
  public void testExecuteSelectOne2() throws Exception {
  public void testExecuteSelectFirst() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "苗子阳");
    cond.put("nickName", "tom");
    JSONObject selectField = new JSONObject();
    selectField.put("name", 1);//1,返回。0不返回
    log.debug("查询结果为:" + noSql.executeSelectOne(cond.toJSONString(), selectField.toJSONString(), "{\"_id\":1}"));
  }
  /**
   * 查询符合条件的最后一条记录
   * 返回collection里符合条件的最后一条记录
   *
   * @throws Exception
   */
  }
  /**
   * 查询符合条件的所有数据
   * 查询符合条件的所有数据,并排序
   *
   * @throws Exception
   */
  public void testExecuteSelect() throws Exception {
  public void testExecuteSelectWithSort() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "tom");
    JSONObject sort = new JSONObject();
  }
  /**
   * 设置返回记录的最大条数，查询符合条件的数据。
   * 查询collection符合条件的数据,设置返回记录的最大条数，
   * 类似mysql的limit
   * 类似oracle的rownum
   * 类似sqlserver的top
   *
   * @throws Exception
   */
  public void testExecuteSelect2() throws Exception {
  public void testExecuteSelectWithCount() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "tom");
    JSONObject sort = new JSONObject();
  }
  /**
   * 查询符合条件，指定返回字段，并对结果排序
   * 查询collection里符合条件的数据:指定返回字段,对结果排序,并设置返回记录的最大条数.
   *
   * @throws Exception
   */
  public void testExecuteSelect3() throws Exception {
  public void testExecuteSelectWithSortAndField() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("nickName", "tom");
    JSONObject sort = new JSONObject();
  /**
   * 大于,大于等于
   * 等于,不等于
   * 小于,小于等于
   *
   * 查询collection里符合比较符条件的数据
   * 比较符: >,>=,=,<=,<,!=
   * @throws Exception
   */
  public void testExecuteSelect4() throws Exception {
  public void testExecuteSelectWithCompare() throws Exception {
    JSONObject cond = new JSONObject();
    //cond.put(MongoConstant.ConditionalOperator.GREATOR_THAN,"4");//大于
    cond.put(MongoConstant.ConditionalOperator.GREATOR_THAN,"4");//大于
    //cond.put(MongoConstant.ConditionalOperator.GREATOR_THAN_OR_EQUAL,"4");//大于等于
    //cond.put(MongoConstant.ConditionalOperator.EQUAL_TO,"3");//等于
    cond.put(MongoConstant.ConditionalOperator.NOT_EQUAL_TO, "3");//不等于
    //cond.put(MongoConstant.ConditionalOperator.NOT_EQUAL_TO, "3");//不等于
    //cond.put(MongoConstant.ConditionalOperator.LESS_THAN,"3");//小于
    //cond.put(MongoConstant.ConditionalOperator.LESS_THAN_OR_EQUAL,"2");//小于等于
    JSONObject param = new JSONObject();
  }
  /**
   * in
   * not in
   *
   * 查询collection里符合范围条件的数据
   * 操作符:in,not in
   * @throws Exception
   */
  public void testExecuteSelect5() throws Exception {
  public void testExecuteSelectWithScope() throws Exception {
    JSONObject cond = new JSONObject();
    String[] data = {"4", "5"};
    //cond.put(MongoConstant.ConditionalOperator.IN,data);//in
  }
  /**
   * and
   * or
   *
   * 查询collection里符合条件的数据
   * 操作符:and, or
   * @throws Exception
   */
  public void testExecuteSelect6() throws Exception {
  public void testExecuteSelectWithAndOr() throws Exception {
    JSONObject param = new JSONObject();
    JSONObject cond1 = new JSONObject();
    JSONObject cond2 = new JSONObject();
  }
  /**
   * not
   * 查询collection里符合条件的数据
   * 操作符:not
   *
   * @throws Exception
   */
  public void testExecuteSelect7() throws Exception {
  public void testExecuteSelectWithNot() throws Exception {
    JSONObject param = new JSONObject();
    JSONObject cond = new JSONObject();
    cond.put(MongoConstant.ConditionalOperator.GREATOR_THAN, "2");
   * order by sumAge asc
   * @throws Exception
   */
  public void testExecuteSelect11() throws Exception {
  public void testExecuteSelectWithManyCondition() throws Exception {
    JSONObject cond = new JSONObject();
    cond.put("name", "{ $ne : \"mike\" }");
    JSONObject sort = new JSONObject();

ipu-mongodb-example/src/test/java/com/ai/ipu/example/mongodb/MongodbExampleWithSql.java

   * 使用标准sql插入一条数据
   *@throws Exception
   */
  public void testExecuteInsert2() throws Exception {
  public void testExecuteInsert() throws Exception {
    JSONObject param = new JSONObject();
    param.put("name", "test");
    log.debug("before insert, num is :" + noSql.takeRecordNum(param.toJSONString()));
   * 使用标准SQL条件查询mongodb(分页)
   * @throws Exception
   */
  public void testExecuteSelect1() throws Exception {
  public void testExecuteSelectWithPage() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 limit 0,5"));
  }
   * 简单的汇总计数
   * @throws Exception
   */
  public void testExecuteSelect2() throws Exception {
  public void testExecuteSelectWithCount() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select count(1) totalNum from mycol1 where name != 'mike' "));
  }
  /**
   * 使用标准SQL查询mongodb
   * 普通查询 升序,降序
   * 排序符:asc,desc
   * @throws Exception
   */
  public void testExecuteSelect3() throws Exception {
    //log.debug("升序查询结果为:" + noSql.executeSelect("select * from mycol1 where name != 'mike' order by age asc"));
    log.debug("降序查询结果为:" + noSql.executeSelect("select * from mycol1 where name != 'mike' order by age desc"));
  public void testExecuteSelectWithSort() throws Exception {
    log.debug("升序查询结果为:" + noSql.executeSelect("select * from mycol1 where name != 'mike' order by age asc"));
    //log.debug("降序查询结果为:" + noSql.executeSelect("select * from mycol1 where name != 'mike' order by age desc"));
  }
  /**
   * 使用标准SQL查询mongodb
   * 条件:大于,小于,等于
   * 比较符: >,>=,=,<=,<,!=
   * @desc 当前age列插入的是数值型,如果是字符型,以大于条件为例:where age > '20';
   * @throws Exception
   */
  public void testExecuteSelect4() throws Exception {
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age > 20"));
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age = 20"));
  public void testExecuteSelectWithCompare() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age > 20"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age = 20"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age < 20"));
  }
  /**
   * 使用标准SQL查询mongodb
   * 条件:大于等于,小于等于
   * @throws Exception
   */
  public void testExecuteSelect5() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age >= 20"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age >= 20"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age <= 20"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age != 20"));
  }
  /**
   * 使用标准SQL查询mongodb
   * 条件:in,not in
   * 操作符号:in,not in,and,or
   * @desc 当前age列插入的是数值型,如果是字符型,以IN操作符为例: in('10','20');
   * @throws Exception
   */
  public void testExecuteSelect6() throws Exception {
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age in (10,20)"));
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age not in (20)"));
  }
  /**
   * 使用标准SQL查询mongodb
   * 条件:and,or
   * @throws Exception
   */
  public void testExecuteSelect7() throws Exception {
  public void testExecuteSelectWithScope() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age in (10,20)"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age not in (20)"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age >= 20 and age < 21"));
    log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age >= 20 or age < 21"));
    //log.debug("查询结果为:" + noSql.executeSelect("select * from mycol1 where age >= 20 or age < 21"));
  }
  /**
   * 使用标准SQL查询mongodb
   * 使用标准SQL多条件查询mongodb
   * 条件:group by,having,order by
   * 分类汇总
   * @throws Exception
   */
  public void testExecuteSelect8() throws Exception {
  public void testExecuteSelectWithManyCondition() throws Exception {
    log.debug("查询结果为:" + noSql.executeSelect("select name,nickName,sum(age) sumAge,count(1) totalNum from mycol1 where name != 'mike' group by name,nickName  having sumAge>=10 order by sumAge desc"));
  }
}