<<  Flex 3 Maven Built Locales | 首 页 |

  • Hibernate with Oracle xmltype - [〓 左道旁门 〓]

    2011-02-21

    分类: 〓 左道旁门 〓

    版权声明：转载时请以超链接形式标明文章原始出处和作者信息及本声明
    http://solecjj.blogbus.com/logs/106244704.html

    1. Create a table in DB
    create table J_TEST (
    id number,
    j_xml xmltype)

     2. POJO
    package test.oracle.xml;

    import org.w3c.dom.Document;

    public class XMLBean {

        private Long id = null;

        private Document xmlDoc = null;

        public Long getId() {
            return id;
        }

        public void setId(Long id) {
            this.id = id;
        }

        public Document getXmlDoc() {
            return xmlDoc;
        }

        public void setXmlDoc(Document xmlDoc) {
            this.xmlDoc = xmlDoc;
        }

    }

    3 Hibernate hbm
     


    "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">

       
           
               
               
           
           
               
           
           


    4 Hibernate User Defiined Type

    package test.oracle.xml;

    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.io.Serializable;
    import java.io.StringWriter;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;

    import javax.xml.parsers.DocumentBuilder;
    import javax.xml.parsers.DocumentBuilderFactory;
    import javax.xml.parsers.ParserConfigurationException;
    import javax.xml.transform.OutputKeys;
    import javax.xml.transform.Transformer;
    import javax.xml.transform.TransformerException;
    import javax.xml.transform.TransformerFactory;
    import javax.xml.transform.dom.DOMSource;
    import javax.xml.transform.stream.StreamResult;

    import oracle.jdbc.OracleResultSet;
    import oracle.jdbc.driver.OraclePreparedStatement;
    import oracle.sql.OPAQUE;
    import oracle.xdb.XMLType;

    import org.hibernate.HibernateException;
    import org.hibernate.usertype.UserType;
    import org.w3c.dom.Document;
    import org.xml.sax.SAXException;

    public class OracleXMLType implements UserType, Serializable {
        // all other methods are ommitted at present for brevity

        private static final long serialVersionUID = 2308230823023l;
        private static final Class returnedClass = Document.class;
        private static final int[] SQL_TYPES = new int[] { oracle.xdb.XMLType._SQL_TYPECODE };

        public int[] sqlTypes() {
            return SQL_TYPES;
        }

        public Class returnedClass() {
            return returnedClass;
        }

        public int hashCode(Object _obj) {
            return _obj.hashCode();
        }

        public Object assemble(Serializable _cached, Object _owner)
                throws HibernateException {
            try {
                return OracleXMLType.stringToDom((String) _cached);
            } catch (Exception e) {
                throw new HibernateException(
                        "Could not assemble String to Document", e);
            }
        }

        public Serializable disassemble(Object _obj) throws HibernateException {
            try {
                return OracleXMLType.domToString((Document) _obj);
            } catch (Exception e) {
                throw new HibernateException(
                        "Could not disassemble Document to Serializable", e);
            }
        }

        public Object replace(Object _orig, Object _tar, Object _owner) {
            return deepCopy(_orig);
        }

        public boolean equals(Object arg0, Object arg1) throws HibernateException {
            if (arg0 == null && arg1 == null)
                return true;
            else if (arg0 == null && arg1 != null)
                return false;
            else
                return arg0.equals(arg1);
        }

        public Object nullSafeGet(ResultSet rs, String[] names, Object arg2)
                throws HibernateException, SQLException {
            XMLType xmlType = null;
            Document doc = null;
            try {
                OPAQUE op = null;
                OracleResultSet ors = null;
                if (rs instanceof OracleResultSet) {
                    ors = (OracleResultSet) rs;
                } else {
                    throw new UnsupportedOperationException(
                            "ResultSet needs to be of type OracleResultSet");
                }
                op = ors.getOPAQUE(names[0]);
                if (op != null) {
                    xmlType = XMLType.createXML(op);
                }
                doc = xmlType.getDOM();
            } finally {
                if (null != xmlType) {
                    xmlType.close();
                }
            }
            return doc;
        }

        public void nullSafeSet(PreparedStatement st, Object value, int index)
                throws HibernateException, SQLException {
            try {
                XMLType xmlType = null;
                if (value != null) {
                    xmlType = XMLType.createXML(st.getConnection(),
                            OracleXMLType.domToString((Document) value));
                } else {
                    xmlType = XMLType.createXML(st.getConnection(), "");
                }

                ((OraclePreparedStatement) st).setObject(index, xmlType);
            } catch (Exception e) {
                throw new SQLException(
                        "Could not convert Document to String for storage");
            }
        }

        public Object deepCopy(Object value) throws HibernateException {
            if (value == null)
                return null;

            return (Document) ((Document) value).cloneNode(true);
        }

        public boolean isMutable() {
            return false;
        }

        protected static String domToString(Document _document)
                throws TransformerException {
            TransformerFactory tFactory = TransformerFactory.newInstance();
            Transformer transformer = tFactory.newTransformer();
            transformer.setOutputProperty(OutputKeys.INDENT, "yes");
            DOMSource source = new DOMSource(_document);
            StringWriter sw = new StringWriter();
            StreamResult result = new StreamResult(sw);
            transformer.transform(source, result);
            return sw.toString();
        }

        protected static Document stringToDom(String xmlSource)
                throws SAXException, ParserConfigurationException, IOException {
            DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
            DocumentBuilder builder = factory.newDocumentBuilder();
            ByteArrayInputStream inputStream = new ByteArrayInputStream(
                    xmlSource.getBytes("UTF-8"));
            Document document = builder.parse(inputStream);
            return document;
        }
    }


    5 Hibernate User Defined Dialect
    package test.oracle.xml;

    import org.hibernate.dialect.Oracle9iDialect;

    public class UserDefinedOracleDialect extends Oracle9iDialect {
        public UserDefinedOracleDialect() {
            super();
            registerHibernateType(oracle.xdb.XMLType._SQL_TYPECODE, "xmltype");
            registerColumnType(oracle.xdb.XMLType._SQL_TYPECODE, "xmltype");
        }
    }


    6 Hibernate configuration


            "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
            "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">


        
            jdbc:oracle:thin:@host:port:dbName
            userName
            password
            oracle.jdbc.driver.OracleDriver
             org.hibernate.cache.NoCacheProvider
            
            test.oracle.xml.UserDefinedOracleDialect
            true
            validate
            
        


    7 Testor

    package test.oracle.xml;

    import java.io.StringWriter;

    import javax.xml.parsers.DocumentBuilder;
    import javax.xml.parsers.DocumentBuilderFactory;
    import javax.xml.transform.OutputKeys;
    import javax.xml.transform.Transformer;
    import javax.xml.transform.TransformerFactory;
    import javax.xml.transform.dom.DOMSource;
    import javax.xml.transform.stream.StreamResult;

    import org.hibernate.Session;
    import org.hibernate.cfg.Configuration;
    import org.w3c.dom.Document;

    public class XMLTestor {

        /**
         * @param args
         */
        public static void main(String[] args) throws Exception {
            DocumentBuilderFactory docFactory = DocumentBuilderFactory
                    .newInstance();
            DocumentBuilder docBuilder = docFactory.newDocumentBuilder();
            org.xml.sax.InputSource inStream = new org.xml.sax.InputSource();
            inStream.setCharacterStream(new java.io.StringReader(""));

            Document doc = docBuilder.parse(inStream);

            Session session = new Configuration()
                    .configure("hibernate.test.cfg.xml").buildSessionFactory()
                    .openSession();
            XMLBean bean = new XMLBean();
            session.getTransaction().begin();
            
            bean.setXmlDoc(doc);
            session.save(bean);
            session.flush();
            
            session.getTransaction().commit();

            XMLBean loadedBean = (XMLBean) session.load(XMLBean.class, bean.getId());
            Transformer transformer = TransformerFactory.newInstance()
                    .newTransformer();
            transformer.setOutputProperty(OutputKeys.INDENT, "yes");


            StreamResult result = new StreamResult(new StringWriter());
            DOMSource source = new DOMSource(loadedBean.getXmlDoc());
            transformer.transform(source, result);

            String xmlString = result.getWriter().toString();
            System.out.println(xmlString);
            session.close();
        }

    }


    8 maven pom dependecies
       
           
                org.hibernate
                hibernate-core
                3.3.2.GA
           
           
                oracle
                xmlparserv2
                9i
           
           
                oracle
                xdb
                9i
           
       
          
     


    收藏到：Del.icio.us




    Tag：hibernate oracle
    引用地址：
    无用 发表于21:21 | 编辑 | 分享　0