xmlsources.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 java.sql.Types;
import java.util.ArrayList;

import org.w3c.dom.Element;


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 XMLSources extends XMLNode {

	public static final String NAME="Sources";

	String sqlCompareProcedures="SELECT COUNT(*) FROM COMPARE_PROCEDURES WHERE SRC_OWNER=? ";
	String sqlComparePackages="SELECT COUNT(*) FROM COMPARE_PACKAGES WHERE SRC_OWNER=? ";
	String sqlComparePackageBodies="SELECT COUNT(*) FROM COMPARE_PACKAGE_BODIES WHERE SRC_OWNER=? ";
	String sqlCompareFunctions="SELECT COUNT(*) FROM COMPARE_FUNCTIONS WHERE SRC_OWNER=? ";


	public XMLSources() throws NodeException{
		super();
		this.name=NAME;

	} 

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

	/**从数据库中获取数据对象比较后的结果*/
	public void refreshChangedProperties()throws Exception{

		if(hasProcedures()){
			XMLProcedures Procedures=new XMLProcedures();
			Procedures.setCompareStatus(ComparedNode.COMPARED);
			this.addChild(Procedures);
		}
		if(hasFunctions()){
			XMLFunctions Functions=new XMLFunctions();
			Functions.setCompareStatus(ComparedNode.COMPARED);
			this.addChild(Functions);
		}

		if(hasPackages()){
			XMLPackages Packages=new XMLPackages();
			Packages.setCompareStatus(ComparedNode.COMPARED);
			this.addChild(Packages);
		}
			
		if(hasPackageBodies()){
			XMLPackageBodies PackageBodies=new XMLPackageBodies();
			PackageBodies.setCompareStatus(ComparedNode.COMPARED);
			this.addChild(PackageBodies);
		}
			
	}
	
	/**从数据库中获取数据对象定义*/
	public void refreshDDLInfo()throws Exception{

		this.addChild(new XMLFunctions());
		this.addChild(new XMLPackages());
		this.addChild(new XMLPackageBodies());
		this.addChild(new XMLProcedures());
	}


	/**
	 * @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_FUNCTIONS) return true;
		if(node.getType()==XMLNode.XML_PACKAGEBODIES) return true;
		if(node.getType()==XMLNode.XML_PACKAGES) return true;
		if(node.getType()==XMLNode.XML_PROCEDURES) 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) {
	}
	
	boolean hasProcedures(){
		return hasObjects(sqlCompareProcedures);
	}
	
	boolean hasPackages(){
		return hasObjects(sqlComparePackages);
	}

	boolean hasPackageBodies(){
		return hasObjects(sqlComparePackageBodies);
	}
	
	boolean hasFunctions(){
		return hasObjects(sqlCompareFunctions);
	}

	
	boolean hasObjects(String sql){
		boolean result=false;
		
		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 false;

			PreparedStatement pStmt=cnn.prepareStatement(sql);
			pStmt.setString(1,this.getSchema().getName());
			//pStmt.setString(2,this.getName());
			ResultSet rs=pStmt.executeQuery();
			if(rs.next()&&rs.getLong(1)>0) result=true;
			else result=false;
			
			rs.close();
			pStmt.close();

			return result;				
		} catch (Exception e) {
			e.printStackTrace();
			Logger.log(Logger.ERROR,e.getMessage());
			return false;
		}
	}	
}