Как указать sql диалект при создании искровых данных из JDBC?
У меня проблема с чтением данных через пользовательский JDBC со Spark. Как бы я мог переопределить sql диалект, выведенный через URL-адрес jdbc?
База данных, о которой идет речь, является vitess (https://github.com/youtube/vitess), который запускает вариант MySQL, поэтому я хочу указать MySQL диалект. URL-адрес jdbc начинается с jdbc: vitess /
В противном случае DataFrameReader выводит диалект по умолчанию, который использует "" "в качестве идентификатора кавычки. В результате запросы через spark.read.jdbc отправляются как
Выберите 'id', 'col2', col3 ',' etc 'из таблицы
который выбирает строковые представления вместо значений столбцов вместо
Выберите id, col2, col3 и т. Д. Из таблицы