xmlpackagebodies.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.JDBCException;
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 XMLPackageBodies extends XMLNode {
	public static String NAME="Package Bodies";
	
	String crComparedPackages="SELECT SRC_PACKAGE_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_PACKAGE_NAME FROM COMPARE_PACKAGE_BODIES WHERE SRC_OWNER=? AND  ATTR_NAME='MYSTYLE'";
	String upComparedPackages="SELECT SRC_PACKAGE_NAME,ATTR_NAME,SRC_ATTR_VALUE,DST_ATTR_VALUE FROM COMPARE_PACKAGE_BODIES WHERE SRC_OWNER=?  AND ATTR_NAME<>'MYSTYLE'";
	
	private String sqlPackages = "select name, MAX(LINE) from DBA_SOURCE where type='PACKAGE BODY' and owner=? GROUP BY NAME";
	private String sqlPackagesWrapped="select name from DBA_SOURCE where type='PACKAGE BODY' and line=1 and owner=? and text like '% wrapped%'";
	private String text = "";
	//private boolean wrapped = false;
	
	/**
	 * Constructor for XMLManager.
	 */
	public XMLPackageBodies() {
		super();
		this.name=NAME;
		this.setParent(null);
	}

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


	/**从数据库中获取数据对象比较后的结果*/
	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(crComparedPackages);
		pStmt.setString(1,this.getSchema().getName().toUpperCase());
		ResultSet rsCrPackages=pStmt.executeQuery();
		
		while(rsCrPackages.next()){
			XMLPackageBody Package=null;
			byte status=XMLNode.toCompareStatus(rsCrPackages.getString("SRC_ATTR_VALUE"));
			if(status==XMLNode.SRC_NULL_DST_EXIST)
				Package=new XMLPackageBody(rsCrPackages.getString("DST_PACKAGE_NAME"));
			else
				Package=new XMLPackageBody(rsCrPackages.getString("SRC_PACKAGE_NAME"));

			Package.setCompareStatus(status);
			this.addChild(Package);
		}
		rsCrPackages.close();

		//再修改比较节点
		pStmt=cnn.prepareStatement(upComparedPackages);
		pStmt.setString(1,this.getSchema().getName().toUpperCase());
		ResultSet rsUpPackages=pStmt.executeQuery();

		while(rsUpPackages.next()){
			XMLPackageBody Package1=(XMLPackageBody)this.getDirectChildren(XMLNode.XML_PACKAGEBODY,rsUpPackages.getString("SRC_PACKAGE_NAME"));
			Package1.putChangedProperty(rsUpPackages.getString("ATTR_NAME"),rsUpPackages.getString("SRC_ATTR_VALUE"),rsUpPackages.getString("DST_ATTR_VALUE"));				
		}
		rsUpPackages.close();
		pStmt.close();						
	}
	
	/**从数据库中获取数据对象定义*/
	public void refreshDDLInfo()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;
		

		//获取Package body列表
		PreparedStatement pStmt=cnn.prepareStatement(this.sqlPackages);
		pStmt.setString(1,this.getParent().getParent().getName().toUpperCase());
		ResultSet rsPackageBodies=pStmt.executeQuery();
		while(rsPackageBodies.next()){
			XMLPackageBody packbody=new XMLPackageBody(rsPackageBodies.getString(1).trim());
			if(rsPackageBodies.getInt(2)>XMLNode.MAX_SOURCE_LINES)
				packbody.setOverflow(true);
			this.addChild(packbody);
		}
		pStmt.close();
		rsPackageBodies.close();

		//获取Package body列表
		PreparedStatement pStmt1=cnn.prepareStatement(this.sqlPackagesWrapped);
		pStmt1.setString(1,this.getParent().getParent().getName().toUpperCase());
		ResultSet rsPackageBodiesWrapped=pStmt1.executeQuery();
		while(rsPackageBodiesWrapped.next()){
			XMLPackageBody packbody=(XMLPackageBody)this.getDirectChildren(XMLNode.XML_PACKAGEBODY,rsPackageBodiesWrapped.getString(1).trim());
			packbody.setWrapped(true);
		}
		pStmt1.close();
		rsPackageBodiesWrapped.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_PACKAGEBODY) 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) {
	}
}