У меня есть данные CSV, как показано ниже:
Ключ 1 = значение 1, Ключ 2 = значение 2, Ключ 3 = значение 3, Ключ 4 = значение 4, Ключ 5 = значение 5, Ключ 6 = значение6
У меня есть таблица со следующими столбцами:
Col1 (ключ1) = значение 1, Col4 (ключ 4) = значение 4, Col5 (ключ 5) = значение 5
Мне нужно проверить, есть ли столбцы в CSV в TABLE и имеют ли они те же данные
public List<Map<String, String>> parse(Path csvPath) throws IOException {
Reader in = new FileReader(csvPath.toFile());
Iterable<CSVRecord> records = CSVFormat.DEFAULT
.withFirstRecordAsHeader()
.withIgnoreEmptyLines(true)
.withDelimiter(',')
.withTrim()
.parse(in);
return StreamSupport
.stream(records.spliterator(), false)
.filter(csvRecord -> Integer.parseInt(csvRecord.get("Col 4"))>0)
.map(csvRecord -> csvRecord.toMap().entrySet().stream()
.collect(Collectors.toMap(
e -> e.getKey(),
e -> e.getValue()
)))
.collect(Collectors.toList());
}
// ТАБЛИЦА ДАННЫХ //
public int CassandraConn(){
// TODO Auto-generated method stub
String cqlStatement = "select * from table_name;
for (Row row : session.execute(cqlStatement)) {
System.out.println(row.toString());
}
}