import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.loushang.persistent.jdbc.datasource.PropertyDataSourceFactoryImpl;

public class DataBaseUtil {
 private static Log logger = LogFactory.getLog(DataBaseUtil.class);
 
 public static final String DATASOURCE_FILENAME = "datasource.properties"; //连接数据库的数据源文件
 public static final String DATASOURCE_URL = "dataSource.url";             //数据源文件里url的key
 public static final String DATASOURCE_USERNAME = "dataSource.username";   //数据源文件里用户名的key
 
 /**
  * 读取配置文件信息
  * @return Properties 配置文件信息
  */
 public static Properties getProperties() {
  //InputStream in = ClassLoader.getSystemResourceAsStream(DATASOURCE_FILENAME);
  
  InputStream in = PropertyDataSourceFactoryImpl.class.getClassLoader()
    .getResourceAsStream(DATASOURCE_FILENAME);
  if (in == null) {
   in = Thread.currentThread().getContextClassLoader().getResourceAsStream(DATASOURCE_FILENAME);
   if(in == null){
    logger.warn("Can not find the  datasource config file ‘datasource.properties‘.");
   }
  }
  Properties properties = new Properties();
  try {
   properties.load(in);
  } catch (IOException e) {
   logger.error("Error occurred when loading datasource config file.", e);
  }
  return properties;
 }
 /**
  * 读取配置文件获取连接数据库的数据库名
  * @return String 数据库名
  */
 public static String getDatabaseName() {
  String databaseName = "";  
  Properties p = getProperties();
  String database = p.getProperty(DATASOURCE_URL);
  int startIndex = database.lastIndexOf(":");
  databaseName = database.substring(startIndex+1, database.length());  
  return databaseName;
 }
 /**
  * 读取配置文件获取连接数据库的用户名
  * @return String 用户名
  */
 public static String getUserOfDatabase() {
  String user = "";
  Properties p = getProperties();
  user = p.getProperty(DATASOURCE_USERNAME);
  return user;
 }
 /**
  * 获取指定数据库和用户的所有表名
  * @param conn 连接数据库对象
  * @param user 用户
  * @param database 数据库名
  * @return
  */
 public static List getAllTableNames(Connection conn, String user, String database) {
  List tableNames = new ArrayList();
  if (conn != null) {
   try {
    DatabaseMetaData dbmd = conn.getMetaData();
    // 表名列表
    ResultSet rest = dbmd.getTables(database, null, null, new String[] { "TABLE" });
    // 输出 table_name
    while (rest.next()) {
     String tableSchem = rest.getString("TABLE_SCHEM");
     if (user.equalsIgnoreCase(tableSchem)) {
      tableNames.add(rest.getString("TABLE_NAME"));
     }
    }
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
  return tableNames;
 }
  public static void main(String [] args) {
  Connection conn = null;     
     try{
     /* String url="jdbc:oracle:thin:@10.*.*.*:1521:***";
         Class.forName("oracle.jdbc.driver.OracleDriver");
         conn = DriverManager.getConnection(url , "*" , "*");*/
  
     DataSource datasource = DataSourceFactory.defaultFactory.getDataSource("dataSource");
     conn = datasource.getConnection();
  } catch (SQLException e1) {
   e1.printStackTrace();
  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  }
  List tables = getAllTableNames(conn, getUserOfDatabase(), getDatabaseName());
  System.out.println(tables.size());
  
 }
}