Connect to a database with DatabaseMeta
Todo:
Describe how to create a database connection and use it to access a database.
So far:
- Create a DatabaseMeta and fill it with connection information
- Create a new Database using the DatabaseMeta
- Connect with the database
- Query away
- Shut it all down
public static void main(String[] args) { try { KettleEnvironment.init(); DatabaseMeta dbm = new DatabaseMeta(); dbm.setDatabaseInterface(DatabaseMeta.getDatabaseInterface("Hadoop Hive")); dbm.setName("DB Conn"); dbm.setHostname("server.domain.com"); dbm.setDBName("default"); dbm.setDBPort("10000"); Database db = new Database(null, dbm); db.connect(); ResultSet rs = db.openQuery("select * from account"); if(rs != null) { System.out.println(""); System.out.println(""); int colWidth = 20; int colCount = rs.getMetaData().getColumnCount(); for(int i = 1; i < colCount; i++) { System.out.print(HiveTest.fill(rs.getMetaData().getColumnName(i), colWidth)); } System.out.println(""); while(rs.next()) { // Do something with your data } db.closeQuery(rs); } db.disconnect(); } catch(Throwable e) { e.printStackTrace(); } }