Advertisement
Guest User

Untitled

a guest
Mar 3rd, 2018
96
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.71 KB | None | 0 0
  1. String myDriver = "com.mysql.jdbc.Driver";
  2. String myUrl = "jdbc:mysql://localhost:3306/rsds_data";
  3. Class.forName(myDriver);
  4. Connection conn = DriverManager.getConnection(myUrl, "root", "");
  5. String query = "SELECT * FROM slowa_kluczowe";
  6. Statement st = conn.createStatement();
  7. ResultSet rs = st.executeQuery(query);
  8.  
  9. List<Row> rows = new ArrayList<>();
  10. rs.next();
  11. Row row = RowFactory.create(JdbcRDD.resultSetToObjectArray(rs));
  12. rows.add(row);
  13.  
  14. Dataset<Row> df = sparkSession.createDataFrame(rows, jdbcDF.schema());
  15. df.printSchema();
  16. df.show();
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement