xmlconscolumns.java

来自「导出ORACLE数据库对象DDL语句的程序」· Java 代码 · 共 119 行

package com.icbcsdc.ddlexp.pub.xml.nodeinfo;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;

import com.icbcsdc.ddlexp.pub.connectionpool.JDBCPool;
import com.icbcsdc.ddlexp.pub.connectionpool.JDBCPoolManager;
import com.icbcsdc.ddlexp.pub.staticLog.Logger;

/**
 * @author zhangyc
 *
 * To change this generated comment edit the template variable "typecomment":
 * Window>Preferences>Java>Templates.
 * To enable and disable the creation of type comments go to
 * Window>Preferences>Java>Code Generation.
 */
public class XMLConsColumns extends XMLNode {
	public static final String NAME="Constraint Columns";
	String crComparedColSql="SELECT SRC_COLUMN_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_COLUMN_NAME from compare_cons_columns WHERE ATTR_NAME='MYSTYLE' and SRC_OWNER=? and SRC_CONSTRAINT_NAME=?";
	String upComparedColSql="SELECT SRC_COLUMN_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_ATTR_VALUE from compare_cons_columns WHERE ATTR_NAME='MYSTYLE' and SRC_OWNER=? and SRC_CONSTRAINT_NAME=?";

	
	public XMLConsColumns(){
		this.name=NAME;
	}
	
	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#getType()
	 */
	public int getType() {
		return XMLNode.XML_CONSCOLUMNS;
	}

	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#chkChildType(XMLNode)
	 */
	public boolean chkChildType(XMLNode node) {
		if(node.getType()==XMLNode.XML_CONSCOLUMN) return true;
		return false;
	}

	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#getSqlDDL()
	 */
	public String getSqlDDL() {
		return null;
	}

	public void refresh()throws Exception{
		this.clear();
		refreshNodeNeedAccessDB();		
		super.refresh();
	}

	/**从数据库中获取数据对象比较后的结果*/
	public void refreshChangedProperties()throws Exception{
		JDBCPool cnn=null;
		//try {
			//XMLManager.getInstance().
		XMLDatabase db=this.getDatabase();
			
		if(db!=null) cnn = db.getConnPool();
		else return;

		//先创建比较节点
		PreparedStatement pStmt=cnn.prepareStatement(crComparedColSql);
		pStmt.setString(1,this.getSchema().getName().toUpperCase());
		pStmt.setString(2,this.getTable().getName().toUpperCase());
		pStmt.setString(3,this.getParent().getName().toUpperCase());
		ResultSet rsCrTabCols=pStmt.executeQuery();
		
		while(rsCrTabCols.next()){
			XMLConsColumn col=null;
			byte status=XMLNode.toCompareStatus(rsCrTabCols.getString("SRC_ATTR_VALUE"));
			if(status==XMLNode.SRC_NULL_DST_EXIST)
				col=new XMLConsColumn(this.getTable().getName(),rsCrTabCols.getString("DST_INDEX_NAME"));
			else
				col=new XMLConsColumn(this.getTable().getName(),rsCrTabCols.getString("SRC_INDEX_NAME"));

			col.setCompareStatus(status);
			this.addChild(col);
		}
		rsCrTabCols.close();

		//再修改比较节点
		pStmt=cnn.prepareStatement(upComparedColSql);
		pStmt.setString(1,this.getSchema().getName().toUpperCase());
		pStmt.setString(2,this.getTable().getName().toUpperCase());
		pStmt.setString(3,this.getParent().getName().toUpperCase());
		ResultSet rsUpTabColumns=pStmt.executeQuery();

		while(rsUpTabColumns.next()){
			XMLConsColumn col1=(XMLConsColumn)this.getDirectChildren(XMLNode.XML_CONSCOLUMN,rsUpTabColumns.getString("SRC_INDEX_NAME"));
			col1.putChangedProperty(rsUpTabColumns.getString("ATTR_NAME"),rsUpTabColumns.getString("SRC_ATTR_VALUE"),rsUpTabColumns.getString("DST_ATTR_VALUE"));				
		}

		rsUpTabColumns.close();
		pStmt.close();
		/**
		} catch (Exception e) {
			e.printStackTrace();
			Logger.log(Logger.ERROR,e.getMessage());
		}
		**/
	}
	
	/**从数据库中获取数据对象定义*/
	public void refreshDDLInfo()throws Exception{
		ArrayList list=((XMLConstraint)this.getParent()).getColumns();
		for(int i=0;i<list.size();i++){
			XMLConsColumn col=(XMLConsColumn)list.get(i);
			this.addChild(col);
		}		
	}

}