package turing;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import java.util.Vector;

class  DB
{
	Connection conn = null;
	Statement stmt = null;
	ResultSet rs = null;
		
	public  void dbStart(String DatabaseName,String user,String password ) throws Exception
	{
		String sDBDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
		Class.forName(sDBDriver);
		String sConnStr = "jdbc:microsoft:sqlserver://localhost;DatabaseName="+DatabaseName;  

		conn = DriverManager.getConnection(sConnStr,user,password); 
		stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE ,ResultSet.CONCUR_READ_ONLY);	 		
	}
	
	
	public  void  dbClose() throws Exception
	{
		stmt.close(); 
		conn.close();	
	}
	
			
	public  Vector listTables() throws Exception
	{	
	    Vector v=new Vector();	
        DatabaseMetaData dbmd = conn.getMetaData();
        String[] types = {"TABLE"};
        ResultSet resultSet = dbmd.getTables(null, null, "%", types);
        while (resultSet.next()) 
		{
            String tableName = resultSet.getString(3);
			if(tableName.equals("dtproperties")==false)
			{
				v.add(tableName);	
			}			
        }
		return v;
	}
	
	
	public Vector listColumns(String tableName) throws Exception
	{
	    Vector v=new Vector();
	    		
		String sql="select * from "+tableName;
		ResultSet rs=stmt.executeQuery(sql);
	
		ResultSetMetaData rmt;
		rmt = rs.getMetaData() ;
	
		int n=0;
		for(int i=1;i<=rmt.getColumnCount();i++)
		{
			//System.out.println(rmt.getColumnName(i)+","+rmt.getColumnTypeName(i)  );
			Column c=new Column(rmt.getColumnName(i), rmt.getColumnTypeName(i));
			v.add(c);
			if(c.isIdentity)  n++;
		}
		if(n==0) 
		{
			System.out.println(tableName+"未設(shè)主鍵");
			System.exit(0);
		}
		return v;			
	} 			
}