Прочитать MySQL таблицу в мгновение ока с точными именами столбцов - PullRequest
Новая
       6

Прочитать MySQL таблицу в мгновение ока с точными именами столбцов

0 голосов
/ 26 февраля 2020

Я извлекаю некоторые данные из MySQL, используя flink. 

val selectQuery = "select tconst from titles"
val driverName = "com.mysql.jdbc.Driver"
val sourceDB = "flink_test"
val dbURL = "jdbc:mysql://localhost:3306/"
val dbPassword = "xx"
val dbUser = "root"

val inputBuilder: JDBCInputFormat.JDBCInputFormatBuilder = JDBCInputFormat.buildJDBCInputFormat
  .setDrivername(driverName).setDBUrl(dbURL + sourceDB).setQuery(selectQuery).setRowTypeInfo(rowTypeInfo)
  .setUsername(dbUser).setPassword(dbPassword)

//Get Data from SQL Table
val source = environment.createInput(inputBuilder.finish)

Возвращает источник, но информация о типе строки выглядит так: 

Row(f0: String, f1: String, f2: String, f3: String, f4: Integer, f5: String, f6: String, f7: Integer, f8: String)

Но что я необходимо получить точное имя столбца (tconst), например tconst: String. Есть ли способ сделать это?

...