xmlsequences.java

导出ORACLE数据库对象DDL语句的程序

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

import java.io.InputStream;
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

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

/**
 * @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 XMLSequences extends XMLNode {
	String sqlSequences="SELECT SEQUENCE_NAME,MIN_VALUE,MAX_VALUE,INCREMENT_BY ,CYCLE_FLAG,ORDER_FLAG,CACHE_SIZE FROM DBA_SEQUENCES WHERE SEQUENCE_OWNER=? ORDER BY SEQUENCE_NAME";

	String crComparedSql="SELECT SRC_SEQUENCE_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_SEQUENCE_NAME FROM COMPARE_SEQUENCES WHERE SRC_OWNER=? AND ATTR_NAME='MYSTYLE'";
	String upComparedSql="SELECT SRC_SEQUENCE_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_ATTR_VALUE FROM COMPARE_SEQUENCES WHERE SRC_OWNER=? AND ATTR_NAME<>'MYSTYLE'";	

	public static final String NAME="Sequences";

	public XMLSequences(){
		super();
		this.name=NAME;
	} 

	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#getType()
	 */
	public int getType() {
		return XMLNode.XML_SEQUENCES;
	}

	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#refresh()
	 */
	public void refreshDDLInfo()throws Exception {
		//this.clear();
		JDBCPool cnn=null;
		//try {
		//XMLManager.getInstance().
		XMLDatabase db=this.getDatabase();
		if(JDBCPoolManager.getInstance().isDebug()) 
			System.out.println(this.getClass().toString());
			
		if(db!=null) cnn = db.getConnPool();
		else return;

		if(db.getVersion() == XMLDatabase.VERSION_ORACLE8I){
			String sqlGenDDL = "BEGIN GEN_SEQ_DDL(?); END;";
			CallableStatement cStmt = cnn.prepareCall(sqlGenDDL);
			cStmt.setString(1,this.getSchema().name);
			cStmt.execute();
		}

		//获取schema列表
		PreparedStatement pStmt=cnn.prepareStatement(sqlSequences);			
		pStmt.setString(1,this.getParent().getName().toUpperCase());
		//System.out.println(pStmt.toString());
		//System.out.println(this.getParent().getName().toUpperCase());
		ResultSet rsSequences=pStmt.executeQuery();


		while(rsSequences.next()){
			XMLSequence sequence=new XMLSequence(rsSequences.getString(1),
							rsSequences.getString(2),
							rsSequences.getString(3),
							rsSequences.getString(4));
			//System.out.println(rsSynonyms.getString(1));
			this.addChild(sequence);
		}
		
		pStmt.close();
		rsSequences.close();			
		
		/**
		} catch (Exception e) {
			Logger.log(Logger.ERROR,e.getMessage());
		}**/
		//super.refresh();
	}

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

		//先创建比较节点
		PreparedStatement pStmt=cnn.prepareStatement(crComparedSql);
		pStmt.setString(1,this.getSchema().name.toUpperCase());
		ResultSet rsCrSequences=pStmt.executeQuery();
		while(rsCrSequences.next()){
			XMLSequence sequence0=null;
			byte status=XMLNode.toCompareStatus(rsCrSequences.getString("SRC_ATTR_VALUE"));
			if(status==XMLNode.SRC_NULL_DST_EXIST)
				sequence0=new XMLSequence(rsCrSequences.getString("DST_SEQUENCE_NAME"));
			else
				sequence0=new XMLSequence(rsCrSequences.getString("SRC_SEQUENCE_NAME"));

			sequence0.setCompareStatus(status);
			this.addChild(sequence0);

		}
		rsCrSequences.close();

		//再修改比较节点
		pStmt=cnn.prepareStatement(upComparedSql);
		pStmt.setString(1,this.getSchema().name.toUpperCase());
		ResultSet rsUpSequences=pStmt.executeQuery();
		while(rsUpSequences.next()){
			XMLSequence sequence1=(XMLSequence)this.getDirectChildren(XMLNode.XML_SEQUENCE,rsUpSequences.getString("SRC_SEQUENCE_NAME"));
			sequence1.putChangedProperty(rsUpSequences.getString("ATTR_NAME"),rsUpSequences.getString("SRC_ATTR_VALUE"),rsUpSequences.getString("DST_ATTR_VALUE"));				
		}
		
		rsUpSequences.close();
		pStmt.close();


	}
	
	/**
	 * @see com.icbcsdc.ddlexp.pub.xml.nodeinfo.XMLNode#refresh()
	 */
	public void refresh() throws Exception{
		refreshNodeNeedAccessDB();		
		super.refresh();
	}

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

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

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

	public static void main(String[] args) {
	}
}