private IDatabaseConnection createDatabaseConnection(Connection conn, String schema) {
  IDatabaseConnection dbUnitConn = new DatabaseConnection(conn, schema);
  DatabaseConfig config = dbUnitConn.getConfig();
  config.setProperty(DatabaseConfig.PROPERTY_ESCAPE_PATTERN, "\"?\"");
  config.setProperty(DatabaseConfig.FEATURE_ALLOW_EMPTY_FILEDS, true);

  String dbName = conn.getMetaData().getDatabaseProductName().toLowerCase();
  if (dbName.contains("oracle")) {
    // 注意这里没有使用 OracleDataTypeFactory, 而是自己的 MyOracleDataTypeFactory
    config.setProperty(DatabaseConfig.PROPERTY_DATETYPE_FACTORY, new MyOracleDataTypeFactory());
  } else if (dbName.contains("mysql")) {
    config.setProperty(DatabaseConfig.PROPERTY_DATETYPE_FACTORY, new MySqlDataTypeFactory());
    config.setProperty(DatabaseConfig.PROPERTY_METADATA_HANDLER, new MySqlMetadataHandler());
  }
}

ArgumentCaptor<TestIn> argCaptor = ArgumentCaptor.forClass(TestIn.class);
// 调用 （注意，这里指定了类型，不指定的话有些时候不能正确执行，比如， dao.find(any()) 就不知实际该匹配哪个，可能返回 null）
testService.doMethod(any(TestIn.class)).thenReturn(1);
// 参数收集
verify(testService).doMethod(argCaptor.captor());
// 参数校验
assertEquals("0", argCaptor.getValue().getInArg());

list.stream()
  .filter(item -> item.getDate() <= curDate)
  .collect(Collectors.groupingBy(item -> item.getClass() + "_" + item.getName(),
    Collectors.maxBy(Comparator.comparing(ADto::getScore)))
  .values()
  .stream()
  .collect(Collectors.toList())
  .stream()
  .filter(item -> item.isPresent())
  .map(item -> item.get())
  .collect(Collectors.toList());

Comparator<ADto> comparator = Comparator
  .comparing(ADto::getClass, Comparator.nullsLast(Comparator.naturalOrder()))
  .thenComparing(ADto::getScore, Comparator.nullsLast(Comparator.reverseOrder()))
  .thenComparing(ADto::getName, Comparator.nullsLast(String::compareTo));

list.sort(comparator);