Как записать выражение merge через лямбда выражения:

PreparedStatement s2 = to.prepareStatement("MERGE INTO " + table2 +" target"
+ " USING (SELECT ? DictionaryId,"
+ "? RegistryId) src "

+ "ON (target.DictionaryId=src.DictionaryId)"

+ " WHEN MATCHED THEN UPDATE SET RegistryId=src.RegistryId "


+ "WHEN NOT MATCHED THEN INSERT (DictionaryId, RegistryId)"


+ " VALUES (src.DictionaryId, src.RegistryId)"

+ ";");

- это работает, теперь пробую через ламбда выражения:


PreparedStatement s2 = to.prepareStatement(
"MERGE INTO " + table2 + " target"


+ " USING (SELECT ? Id, ? Name, ? Year) src"
+ " ON (target.Id=src.Id)"


+ " WHEN MATCHED THEN UPDATE SET Name=src.Name, Year=src.Year "

+ "WHEN NOT MATCHED THEN INSERT ("+columns.stream().collect(Collectors.joining(","))+")"
+ " VALUES ("+ columns.stream().collect(Collectors.joining(","))+")"

+ ";");

смог только так, а как полностью через лямбда? Помогите плиз!

пробовал заменить строку:
+ " USING (SELECT ? Id, ? Name, ? Year) src"

на

+ " USING (SELECT " + columns.stream().map((c) ->"?"+c).peek(System.out::println).collect(Collectors.joining(",")) + ") src"

не проходит

Чтобы не писать километры кода, когда надо обработать кучу таблиц, а воспользоваться общим лямбда-выражением

Понравился классический код копирования данных из одной remote таблицы в другую:

PreparedStatement s2 = to.prepareStatement(
"INSERT INTO " + table2 + " ("
+ columns.stream().collect(Collectors.joining(","))
+ ") VALUES ("
+ columns.stream().map(c -> "?").collect(Collectors.joining(",")) + ")" );

хотелось то же проделать c merge, а процедуры это детали

Образец представлен см. выше, tracer и debug для конкретного случая, речь идет об общем случае.

Если крут, собери инструкцию merge на лямбде, а так пустой разговор, я пока собрал на половину и она работает

Просек, как надо:

PreparedStatement s2 = to.prepareStatement(
"MERGE INTO " + table2 + " target"
+ " USING ( SELECT "+ columns.stream().map(c -> "? "+c).peek(System.out::println).collect(Collectors.joining(","))+" ) src"


// + " USING (SELECT ? Id, ? Name, ? Year) src"
+ " ON (target.Id=src.Id)"

+ " WHEN MATCHED THEN UPDATE SET " + columns.stream().map(c -> c+"=src."+c).peek(System.out::println).collect(Collectors.joining(",")) +" "
// + " WHEN MATCHED THEN UPDATE SET Name=src.Name, Year=src.Year "

+ "WHEN NOT MATCHED THEN INSERT ("+columns.stream().collect(Collectors.joining(","))+")"

+ " VALUES ("+ columns.stream().collect(Collectors.joining(","))+")"
// + " VALUES (src.Id, src.Name, src.Year)"
+ ";");