query.py 721 B

123456789101112131415161718192021222324252627282930313233
  1. from py4j.java_gateway import JavaGateway
  2. gateway = JavaGateway()
  3. jdbc_driver = 'com.mysql.jdb.Driver'
  4. db_url = 'jdbc:mysql://localhost/hue'
  5. username = 'root'
  6. password = 'root'
  7. conn = gateway.jvm.java.sql.DriverManager.getConnection(db_url, username, password)
  8. try:
  9. stmt = conn.createStatement()
  10. try:
  11. rs = stmt.executeQuery('select username,email from auth_user')
  12. try:
  13. md = rs.getMetaData()
  14. for i in xrange(md.getColumnCount()):
  15. print md.getColumnTypeName(i + 1)
  16. while rs.next():
  17. username = rs.getString("username")
  18. email = rs.getString("email")
  19. print username, email
  20. finally:
  21. rs.close()
  22. finally:
  23. stmt.close()
  24. finally:
  25. conn.close()