importjava.sql.Connection;

importjava.sql.DatabaseMetaData;

importjava.sql.DriverManager;

importjava.sql.ResultSet;

importjava.util.ArrayList;

importjava.util.HashMap;

importjava.util.Iterator;

importjava.util.Map;

importorg.apache.log4j.Logger;

importcom.alibaba.fastjson.JSON;

publicclassSchemaDetailsTest {

privatestaticfinalLoggerlog= Logger.getLogger(SchemaDetailsTest.class);

publicstaticvoidmain(String[]args)throwsException {

StringdatabaseName="members";

StringuserName="haowa";

Stringpassword="haowa";

StringmySQLPort="6307";

StringhostUrl="172.16.177.139";

SchemaDetailsTestddd=newSchemaDetailsTest();

Map>PAY_TYPE=ddd.getAllColumn(databaseName,userName,password,mySQLPort,

hostUrl);

System.out.println(JSON.toJSONString(PAY_TYPE,true));

}

publicMap> getAllColumn(StringdatabaseName, StringuserName, Stringpassword,

StringmySQLPort, StringhostUrl)throwsException {

Map>PAY_TYPE=newHashMap>();

// Setup the connection with the DB

Class.forName("com.mysql.jdbc.Driver");

Connectionconn= DriverManager.getConnection("jdbc:mysql://"+hostUrl+":"+mySQLPort,userName,password);

// --- LISTING DATABASE SCHEMA NAMES ---

ResultSetresultSet=conn.getMetaData().getCatalogs();

// --- LISTING DATABASE TABLE NAMES ---

String[]types= {"TABLE"};

resultSet=conn.getMetaData().getTables(databaseName,null,"%",types);

StringtableName="";

while(resultSet.next()) {

tableName=resultSet.getString(3);

PAY_TYPE.put(tableName,newArrayList());

}

resultSet.close();

// --- LISTING DATABASE COLUMN NAMES ---

DatabaseMetaDatameta=conn.getMetaData();

Iteratoriiiiii=PAY_TYPE.keySet().iterator();

while(iiiiii.hasNext()) {

StringtempTable=iiiiii.next();

resultSet=meta.getColumns(databaseName,null,tempTable,"%");

while(resultSet.next()) {

StringColumn_Name=resultSet.getString(4);

PAY_TYPE.get(tempTable).add(Column_Name);

}

}

resultSet.close();

conn.close();

returnPAY_TYPE;

}

}