Coverage Report

Coverage Report - org.apache.ojb.broker.metadata.JdbcConnectionDescriptor

Classes in this File

1.404

 package org.apache.ojb.broker.metadata;
 
 /* Copyright 2002-2005 The Apache Software Foundation
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 
 import java.io.Serializable;
 
 import javax.sql.DataSource;
 
 import org.apache.ojb.broker.util.logging.Logger;
 import org.apache.ojb.broker.util.logging.LoggerFactory;
 import org.apache.ojb.broker.PBKey;
 import org.apache.commons.lang.builder.ToStringBuilder;
 import org.apache.commons.lang.builder.ToStringStyle;
 import org.apache.commons.lang.SystemUtils;
 
 /**
  * JdbcConnectionDescriptor describes all relevant parameters of
  * JDBC Connections used by the PersistenceBroker.
  *
  * @author <a href="mailto:thma@apache.org">Thomas Mahler<a>
  * @version $Id: JdbcConnectionDescriptor.java,v 1.1 2007-08-24 22:17:29 ewestfal Exp $
  */
 public class JdbcConnectionDescriptor extends DescriptorBase implements Serializable, XmlCapable
 {
         private static final long serialVersionUID = -600900924512028960L;
     private Logger logger = LoggerFactory.getLogger(JdbcConnectionDescriptor.class);
 
     public static final int AUTO_COMMIT_IGNORE_STATE = 0;
     public static final int AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE = 1;
     public static final int AUTO_COMMIT_SET_FALSE = 2;
 
     private String m_jcdAlias;
     private String m_Dbms;
     private String m_Driver;
     private String m_Protocol;
     private String m_SubProtocol;
     private String m_DbAlias;
     private String m_DatasourceName;
     private String m_UserName;
     private String m_Password;
     private double m_JdbcLevel = 2.0;
     private boolean m_eagerRelease = false;
     private boolean m_batchMode = false;
     private boolean defaultConnection = false;
     private int useAutoCommit = AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE;
     private boolean ignoreAutoCommitExceptions = false;
     private PBKey pbKey;
     private ConnectionPoolDescriptor cpd;
     private SequenceDescriptor sequenceDescriptor;
     private ObjectCacheDescriptor objectCacheDescriptor;
     private transient DataSource dataSource;
 
     /**
      * Constructor declaration
      */
     public JdbcConnectionDescriptor()
     {
         cpd = new ConnectionPoolDescriptor();
         objectCacheDescriptor = new ObjectCacheDescriptor();
     }
 
     /**
      * Returns the appropriate {@link ObjectCacheDescriptor}
      * or <code>null</code> if not specified.
      */
     public ObjectCacheDescriptor getObjectCacheDescriptor()
     {
         return objectCacheDescriptor;
     }
 
     /**
      * Sets the {@link ObjectCacheDescriptor} for representing connection/database.
      */
     public void setObjectCacheDescriptor(ObjectCacheDescriptor objectCacheDescriptor)
     {
         this.objectCacheDescriptor = objectCacheDescriptor;
     }
 
     /**
      * Returns the data source that this connection descriptor represents if any.
      * 
      * @return The data source or <code>null</code>
      */
     public DataSource getDataSource()
     {
         return dataSource;        
     }
 
     /**
      * Sets the data source that this connection descriptor represents.
      * 
      * @param dataSource The data source
      */
     public void setDataSource(DataSource dataSource)
     {
         this.dataSource = dataSource;
     }
 
     /**
      * Get the alias name for this descriptor.
      */
     public String getJcdAlias()
     {
         return m_jcdAlias;
     }
 
     /**
      * Set an alias name for this descriptor.
      */
     public void setJcdAlias(String jcdAlias)
     {
         this.clearPBKey();
         this.m_jcdAlias = jcdAlias;
     }
 
     /**
      *
      */
     public boolean isDefaultConnection()
     {
         return defaultConnection;
     }
 
     public boolean isDataSource()
     {
         return (getDataSource() != null) || (getDatasourceName() != null);
     }
 
     /**
      *
      */
     public void setDefaultConnection(boolean defaultConnection)
     {
         this.defaultConnection = defaultConnection;
     }
 
     /**
      * Return the associated <code>SequenceDescriptor</code>
      * or <code>null</code> if not set.
      */
     public SequenceDescriptor getSequenceDescriptor()
     {
         return sequenceDescriptor;
     }
 
     /**
      * Set the <code>SequenceDescriptor</code> for this
      * connection descriptor.
      */
     public void setSequenceDescriptor(SequenceDescriptor sequenceDescriptor)
     {
         this.sequenceDescriptor = sequenceDescriptor;
     }
 
     /**
      * Returns the connection pool descriptor.
      */
     public ConnectionPoolDescriptor getConnectionPoolDescriptor()
     {
         return cpd;
     }
 
     /**
      * Sets the connection pool descriptor.
      */
     public void setConnectionPoolDescriptor(ConnectionPoolDescriptor cpd)
     {
         this.cpd = cpd;
     }
 
     /**
      * Return a key to identify the connection descriptor.
      */
     public PBKey getPBKey()
     {
         if (pbKey == null)
         {
             this.pbKey = new PBKey(this.getJcdAlias(), this.getUserName(), this.getPassWord());
         }
         return pbKey;
     }
 
     private void clearPBKey()
     {
         this.pbKey = null;
     }
 
     public int getUseAutoCommit()
     {
         return useAutoCommit;
     }
 
     public void setUseAutoCommit(int useAutoCommit)
     {
         this.useAutoCommit = useAutoCommit;
     }
 
     public boolean isIgnoreAutoCommitExceptions()
     {
         return ignoreAutoCommitExceptions;
     }
 
     public void setIgnoreAutoCommitExceptions(boolean ignoreAutoCommitExceptions)
     {
         this.ignoreAutoCommitExceptions = ignoreAutoCommitExceptions;
     }
 
     /**
      * Returns the database platform name.
      */
     public String getDbms()
     {
         return m_Dbms;
     }
 
     /**
      * Sets the database platform name.
      */
     public void setDbms(String str)
     {
         m_Dbms = str;
     }
 
     /**
      * Returns the driver name.
      */
     public String getDriver()
     {
         return m_Driver;
     }
 
     /**
      * Set the database driver.
      */
     public void setDriver(String str)
     {
         m_Driver = str;
     }
 
     /**
      * Returns the database protocol.
      */
     public String getProtocol()
     {
         return m_Protocol;
     }
 
     /**
      * Sets the database protocol.
      */
     public void setProtocol(String str)
     {
         m_Protocol = str;
     }
 
     /**
      * Returns the database sub-protocol.
      */
     public String getSubProtocol()
     {
         return m_SubProtocol;
     }
 
     /**
      * Sets the database sub-protocol.
      */
     public void setSubProtocol(String str)
     {
         m_SubProtocol = str;
     }
 
     /**
      * Returns the database alias name
      * used by OJB.
      */
     public String getDbAlias()
     {
         return m_DbAlias;
     }
 
     /**
      * Sets the database alias name. These
      * names you could find in the repository.dtd.
      */
     public void setDbAlias(String str)
     {
         m_DbAlias = str;
     }
 
     /**
      * Returns the database user name.
      */
     public String getUserName()
     {
         return m_UserName;
     }
 
     /**
      * Sets the database user name.
      */
     public void setUserName(String str)
     {
         this.clearPBKey();
         m_UserName = str;
     }
 
     /**
      * Returns the database password.
      */
     public String getPassWord()
     {
         return m_Password;
     }
 
     /**
      * Sets the database password.
      */
     public void setPassWord(String str)
     {
         this.clearPBKey();
         m_Password = str;
     }
 
     /**
      * Gets the datasourceName.
      * @return Returns a String
      */
     public String getDatasourceName()
     {
         return m_DatasourceName;
     }
 
     /**
      * Sets the datasourceName.
      * @param datasourceName The datasourceName to set
      */
     public void setDatasourceName(String datasourceName)
     {
         m_DatasourceName = datasourceName;
     }
 
     /**
      * Gets the jdbcLevel.
      * @return Returns a String
      */
     public double getJdbcLevel()
     {
         return m_JdbcLevel;
     }
 
     /**
      * Sets the jdbcLevel. parse the string setting and check that it is indeed an integer.
      * @param jdbcLevel The jdbcLevel to set
      */
     public void setJdbcLevel(String jdbcLevel)
     {
         if (jdbcLevel != null)
         {
             try
             {
                 double intLevel = Double.parseDouble(jdbcLevel);
                 setJdbcLevel(intLevel);
             }
             catch(NumberFormatException nfe)
             {
                 setJdbcLevel(2.0);
                 logger.info("Specified JDBC level was not numeric (Value=" + jdbcLevel + "), used default jdbc level of 2.0 ");
             }
         }
         else
         {
             setJdbcLevel(2.0);
             logger.info("Specified JDBC level was null, used default jdbc level of 2.0 ");
         }
     }
 
     public void setJdbcLevel(double jdbcLevel)
     {
         m_JdbcLevel = jdbcLevel;
     }
 
     public boolean getEagerRelease()
     {
             return m_eagerRelease;
     }
 
     public void setEagerRelease(boolean flag)
     {
             m_eagerRelease = flag;
     }
 
     public boolean getBatchMode()
     {
             return m_batchMode;
     }
 
     public void setBatchMode(boolean flag)
     {
             m_batchMode = flag;
     }
 
     /**
      * Returns a String representation of this class.
      */
     public String toString()
     {
         ToStringBuilder buf = new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE);
         buf.
         append("jcd-alias", m_jcdAlias).
         append("default-connection", defaultConnection).
         append("dbms", m_Dbms).
         append("jdbc-level", m_JdbcLevel).
         append("driver", m_Driver).
         append("protocol", m_Protocol).
         append("sub-protocol", m_SubProtocol).
         append("db-alias", m_DbAlias).
         append("user", m_UserName).
         append("password", "*****").
         append("eager-release", m_eagerRelease).
         append("ConnectionPoolDescriptor", cpd).
         append("batchMode", m_batchMode).
         append("useAutoCommit", getUseAutoCommitAsString(useAutoCommit)).
         append("ignoreAutoCommitExceptions", ignoreAutoCommitExceptions).
         append("sequenceDescriptor", sequenceDescriptor);
         return buf.toString();
     }
 
     /*
      * @see XmlCapable#toXML()
      */
     public String toXML()
     {
         RepositoryTags tags = RepositoryTags.getInstance();
         String eol = SystemUtils.LINE_SEPARATOR;
 
         StringBuffer strReturn = new StringBuffer( 1024 );
         strReturn.append( eol );
         strReturn.append( "  <!-- Descriptor for Connection " );
         strReturn.append( getProtocol() );
         strReturn.append( ":" );
         strReturn.append( getSubProtocol() );
         strReturn.append( ":" );
         strReturn.append( getDbAlias() );
         strReturn.append( " -->" );
         strReturn.append( eol );
 
         strReturn.append( "  " );
         strReturn.append( tags.getOpeningTagNonClosingById( JDBC_CONNECTION_DESCRIPTOR ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( JCD_ALIAS, this.getJcdAlias() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( DEFAULT_CONNECTION, "" + this.isDefaultConnection() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( DBMS_NAME, this.getDbms() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( JDBC_LEVEL, "" + this.getJdbcLevel() ) );
         strReturn.append( eol );
 
         //username is optional
         String user = getUserName();
         if( user != null )
         {
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( USER_NAME, user ) );
             strReturn.append( eol );
         }
         // password is optional
         String passwd = getPassWord();
         if( passwd != null )
         {
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( USER_PASSWD, passwd ) );
             strReturn.append( eol );
         }
 
         // JDBC Datasource or DriverManager information are alternatives:
         String dsn = getDatasourceName();
         if( dsn != null )
         {
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( DATASOURCE_NAME, this.getDatasourceName() ) );
             strReturn.append( eol );
         }
         else
         {
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( DRIVER_NAME, this.getDriver() ) );
             strReturn.append( eol );
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( URL_PROTOCOL, this.getProtocol() ) );
             strReturn.append( eol );
             strReturn.append( "    " );
             strReturn.append( tags.getAttribute( URL_SUBPROTOCOL, this.getSubProtocol() ) );
             strReturn.append( eol );
             strReturn.append( "    " );
             strReturn.append( encode( tags.getAttribute( URL_DBALIAS, this.getDbAlias() ) ) );
             strReturn.append( eol );
         }
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( EAGER_RELEASE, "" + this.getEagerRelease() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( BATCH_MODE, "" + this.getBatchMode() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( USE_AUTOCOMMIT, "" + this.getUseAutoCommit() ) );
         strReturn.append( eol );
         strReturn.append( "    " );
         strReturn.append( tags.getAttribute( IGNORE_AUTOCOMMIT_EXCEPTION, "" + this.isIgnoreAutoCommitExceptions() ) );
         strReturn.append( eol );
 
         strReturn.append( "  >" );
         strReturn.append( eol );
         strReturn.append( eol );
 
         strReturn.append( this.getConnectionPoolDescriptor().toXML() );
         strReturn.append( eol );
         if( this.getSequenceDescriptor() != null )
         {
             strReturn.append( this.getSequenceDescriptor().toXML() );
         }
         strReturn.append( eol );
         strReturn.append( "  " );
         strReturn.append( tags.getClosingTagById( JDBC_CONNECTION_DESCRIPTOR ) );
         strReturn.append( eol );
         return strReturn.toString();
     }
 
     private static String encode(String toBeEncoded)
     {
         StringBuffer retval = new StringBuffer();
         char c;
         for (int i=0; i < toBeEncoded.length(); i++)
         {
             c = toBeEncoded.charAt(i);
             if (c == '<')
             {
                 retval.append("&lt;");
             }
             else if (c == '>')
             {
                 retval.append("&gt;");
             }
             //else if (c == '"')
             //{
             //    retval.append("&quot;");
             //}
             else if (c == '&')
             {
                 retval.append("&amp;");
             }
             else if (c == ' ')
             {
                 retval.append("&nbsp;");
             }
             else
             {
                 retval.append(c);
             }
         }
         return retval.toString();
     }
 
     private static String getUseAutoCommitAsString(int state)
     {
         switch (state)
         {
             case AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE:
                 return "AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE";
             case AUTO_COMMIT_SET_FALSE:
                 return "AUTO_COMMIT_SET_FALSE";
             case AUTO_COMMIT_IGNORE_STATE:
                 return "AUTO_COMMIT_IGNORE_STATE";
             default: return "UNKOWN_STATE";
         }
     }
 }

1		package org.apache.ojb.broker.metadata;
2
3		/* Copyright 2002-2005 The Apache Software Foundation
4		*
5		* Licensed under the Apache License, Version 2.0 (the "License");
6		* you may not use this file except in compliance with the License.
7		* You may obtain a copy of the License at
8		*
9		* http://www.apache.org/licenses/LICENSE-2.0
10		*
11		* Unless required by applicable law or agreed to in writing, software
12		* distributed under the License is distributed on an "AS IS" BASIS,
13		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14		* See the License for the specific language governing permissions and
15		* limitations under the License.
16		*/
17
18		import java.io.Serializable;
19
20		import javax.sql.DataSource;
21
22		import org.apache.ojb.broker.util.logging.Logger;
23		import org.apache.ojb.broker.util.logging.LoggerFactory;
24		import org.apache.ojb.broker.PBKey;
25		import org.apache.commons.lang.builder.ToStringBuilder;
26		import org.apache.commons.lang.builder.ToStringStyle;
27		import org.apache.commons.lang.SystemUtils;
28
29		/**
30		* JdbcConnectionDescriptor describes all relevant parameters of
31		* JDBC Connections used by the PersistenceBroker.
32		*
33		* @author <a href="mailto:thma@apache.org">Thomas Mahler<a>
34		* @version $Id: JdbcConnectionDescriptor.java,v 1.1 2007-08-24 22:17:29 ewestfal Exp $
35		*/
36		public class JdbcConnectionDescriptor extends DescriptorBase implements Serializable, XmlCapable
37		{
38		private static final long serialVersionUID = -600900924512028960L;
39		private Logger logger = LoggerFactory.getLogger(JdbcConnectionDescriptor.class);
40
41		public static final int AUTO_COMMIT_IGNORE_STATE = 0;
42		public static final int AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE = 1;
43		public static final int AUTO_COMMIT_SET_FALSE = 2;
44
45		private String m_jcdAlias;
46		private String m_Dbms;
47		private String m_Driver;
48		private String m_Protocol;
49		private String m_SubProtocol;
50		private String m_DbAlias;
51		private String m_DatasourceName;
52		private String m_UserName;
53		private String m_Password;
54		private double m_JdbcLevel = 2.0;
55		private boolean m_eagerRelease = false;
56		private boolean m_batchMode = false;
57		private boolean defaultConnection = false;
58		private int useAutoCommit = AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE;
59		private boolean ignoreAutoCommitExceptions = false;
60		private PBKey pbKey;
61		private ConnectionPoolDescriptor cpd;
62		private SequenceDescriptor sequenceDescriptor;
63		private ObjectCacheDescriptor objectCacheDescriptor;
64		private transient DataSource dataSource;
65
66		/**
67		* Constructor declaration
68		*/
69		public JdbcConnectionDescriptor()
70		{
71		cpd = new ConnectionPoolDescriptor();
72		objectCacheDescriptor = new ObjectCacheDescriptor();
73		}
74
75		/**
76		* Returns the appropriate {@link ObjectCacheDescriptor}
77		* or <code>null</code> if not specified.
78		*/
79		public ObjectCacheDescriptor getObjectCacheDescriptor()
80		{
81		return objectCacheDescriptor;
82		}
83
84		/**
85		* Sets the {@link ObjectCacheDescriptor} for representing connection/database.
86		*/
87		public void setObjectCacheDescriptor(ObjectCacheDescriptor objectCacheDescriptor)
88		{
89		this.objectCacheDescriptor = objectCacheDescriptor;
90		}
91
92		/**
93		* Returns the data source that this connection descriptor represents if any.
94		*
95		* @return The data source or <code>null</code>
96		*/
97		public DataSource getDataSource()
98		{
99		return dataSource;
100		}
101
102		/**
103		* Sets the data source that this connection descriptor represents.
104		*
105		* @param dataSource The data source
106		*/
107		public void setDataSource(DataSource dataSource)
108		{
109		this.dataSource = dataSource;
110		}
111
112		/**
113		* Get the alias name for this descriptor.
114		*/
115		public String getJcdAlias()
116		{
117		return m_jcdAlias;
118		}
119
120		/**
121		* Set an alias name for this descriptor.
122		*/
123		public void setJcdAlias(String jcdAlias)
124		{
125		this.clearPBKey();
126		this.m_jcdAlias = jcdAlias;
127		}
128
129		/**
130		*
131		*/
132		public boolean isDefaultConnection()
133		{
134		return defaultConnection;
135		}
136
137		public boolean isDataSource()
138		{
139		return (getDataSource() != null) \|\| (getDatasourceName() != null);
140		}
141
142		/**
143		*
144		*/
145		public void setDefaultConnection(boolean defaultConnection)
146		{
147		this.defaultConnection = defaultConnection;
148		}
149
150		/**
151		* Return the associated <code>SequenceDescriptor</code>
152		* or <code>null</code> if not set.
153		*/
154		public SequenceDescriptor getSequenceDescriptor()
155		{
156		return sequenceDescriptor;
157		}
158
159		/**
160		* Set the <code>SequenceDescriptor</code> for this
161		* connection descriptor.
162		*/
163		public void setSequenceDescriptor(SequenceDescriptor sequenceDescriptor)
164		{
165		this.sequenceDescriptor = sequenceDescriptor;
166		}
167
168		/**
169		* Returns the connection pool descriptor.
170		*/
171		public ConnectionPoolDescriptor getConnectionPoolDescriptor()
172		{
173		return cpd;
174		}
175
176		/**
177		* Sets the connection pool descriptor.
178		*/
179		public void setConnectionPoolDescriptor(ConnectionPoolDescriptor cpd)
180		{
181		this.cpd = cpd;
182		}
183
184		/**
185		* Return a key to identify the connection descriptor.
186		*/
187		public PBKey getPBKey()
188		{
189		if (pbKey == null)
190		{
191		this.pbKey = new PBKey(this.getJcdAlias(), this.getUserName(), this.getPassWord());
192		}
193		return pbKey;
194		}
195
196		private void clearPBKey()
197		{
198		this.pbKey = null;
199		}
200
201		public int getUseAutoCommit()
202		{
203		return useAutoCommit;
204		}
205
206		public void setUseAutoCommit(int useAutoCommit)
207		{
208		this.useAutoCommit = useAutoCommit;
209		}
210
211		public boolean isIgnoreAutoCommitExceptions()
212		{
213		return ignoreAutoCommitExceptions;
214		}
215
216		public void setIgnoreAutoCommitExceptions(boolean ignoreAutoCommitExceptions)
217		{
218		this.ignoreAutoCommitExceptions = ignoreAutoCommitExceptions;
219		}
220
221		/**
222		* Returns the database platform name.
223		*/
224		public String getDbms()
225		{
226		return m_Dbms;
227		}
228
229		/**
230		* Sets the database platform name.
231		*/
232		public void setDbms(String str)
233		{
234		m_Dbms = str;
235		}
236
237		/**
238		* Returns the driver name.
239		*/
240		public String getDriver()
241		{
242		return m_Driver;
243		}
244
245		/**
246		* Set the database driver.
247		*/
248		public void setDriver(String str)
249		{
250		m_Driver = str;
251		}
252
253		/**
254		* Returns the database protocol.
255		*/
256		public String getProtocol()
257		{
258		return m_Protocol;
259		}
260
261		/**
262		* Sets the database protocol.
263		*/
264		public void setProtocol(String str)
265		{
266		m_Protocol = str;
267		}
268
269		/**
270		* Returns the database sub-protocol.
271		*/
272		public String getSubProtocol()
273		{
274		return m_SubProtocol;
275		}
276
277		/**
278		* Sets the database sub-protocol.
279		*/
280		public void setSubProtocol(String str)
281		{
282		m_SubProtocol = str;
283		}
284
285		/**
286		* Returns the database alias name
287		* used by OJB.
288		*/
289		public String getDbAlias()
290		{
291		return m_DbAlias;
292		}
293
294		/**
295		* Sets the database alias name. These
296		* names you could find in the repository.dtd.
297		*/
298		public void setDbAlias(String str)
299		{
300		m_DbAlias = str;
301		}
302
303		/**
304		* Returns the database user name.
305		*/
306		public String getUserName()
307		{
308		return m_UserName;
309		}
310
311		/**
312		* Sets the database user name.
313		*/
314		public void setUserName(String str)
315		{
316		this.clearPBKey();
317		m_UserName = str;
318		}
319
320		/**
321		* Returns the database password.
322		*/
323		public String getPassWord()
324		{
325		return m_Password;
326		}
327
328		/**
329		* Sets the database password.
330		*/
331		public void setPassWord(String str)
332		{
333		this.clearPBKey();
334		m_Password = str;
335		}
336
337		/**
338		* Gets the datasourceName.
339		* @return Returns a String
340		*/
341		public String getDatasourceName()
342		{
343		return m_DatasourceName;
344		}
345
346		/**
347		* Sets the datasourceName.
348		* @param datasourceName The datasourceName to set
349		*/
350		public void setDatasourceName(String datasourceName)
351		{
352		m_DatasourceName = datasourceName;
353		}
354
355		/**
356		* Gets the jdbcLevel.
357		* @return Returns a String
358		*/
359		public double getJdbcLevel()
360		{
361		return m_JdbcLevel;
362		}
363
364		/**
365		* Sets the jdbcLevel. parse the string setting and check that it is indeed an integer.
366		* @param jdbcLevel The jdbcLevel to set
367		*/
368		public void setJdbcLevel(String jdbcLevel)
369		{
370		if (jdbcLevel != null)
371		{
372		try
373		{
374		double intLevel = Double.parseDouble(jdbcLevel);
375		setJdbcLevel(intLevel);
376		}
377		catch(NumberFormatException nfe)
378		{
379		setJdbcLevel(2.0);
380		logger.info("Specified JDBC level was not numeric (Value=" + jdbcLevel + "), used default jdbc level of 2.0 ");
381		}
382		}
383		else
384		{
385		setJdbcLevel(2.0);
386		logger.info("Specified JDBC level was null, used default jdbc level of 2.0 ");
387		}
388		}
389
390		public void setJdbcLevel(double jdbcLevel)
391		{
392		m_JdbcLevel = jdbcLevel;
393		}
394
395		public boolean getEagerRelease()
396		{
397		return m_eagerRelease;
398		}
399
400		public void setEagerRelease(boolean flag)
401		{
402		m_eagerRelease = flag;
403		}
404
405		public boolean getBatchMode()
406		{
407		return m_batchMode;
408		}
409
410		public void setBatchMode(boolean flag)
411		{
412		m_batchMode = flag;
413		}
414
415		/**
416		* Returns a String representation of this class.
417		*/
418		public String toString()
419		{
420		ToStringBuilder buf = new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE);
421		buf.
422		append("jcd-alias", m_jcdAlias).
423		append("default-connection", defaultConnection).
424		append("dbms", m_Dbms).
425		append("jdbc-level", m_JdbcLevel).
426		append("driver", m_Driver).
427		append("protocol", m_Protocol).
428		append("sub-protocol", m_SubProtocol).
429		append("db-alias", m_DbAlias).
430		append("user", m_UserName).
431		append("password", "*****").
432		append("eager-release", m_eagerRelease).
433		append("ConnectionPoolDescriptor", cpd).
434		append("batchMode", m_batchMode).
435		append("useAutoCommit", getUseAutoCommitAsString(useAutoCommit)).
436		append("ignoreAutoCommitExceptions", ignoreAutoCommitExceptions).
437		append("sequenceDescriptor", sequenceDescriptor);
438		return buf.toString();
439		}
440
441		/*
442		* @see XmlCapable#toXML()
443		*/
444		public String toXML()
445		{
446		RepositoryTags tags = RepositoryTags.getInstance();
447		String eol = SystemUtils.LINE_SEPARATOR;
448
449		StringBuffer strReturn = new StringBuffer( 1024 );
450		strReturn.append( eol );
451		strReturn.append( " <!-- Descriptor for Connection " );
452		strReturn.append( getProtocol() );
453		strReturn.append( ":" );
454		strReturn.append( getSubProtocol() );
455		strReturn.append( ":" );
456		strReturn.append( getDbAlias() );
457		strReturn.append( " -->" );
458		strReturn.append( eol );
459
460		strReturn.append( " " );
461		strReturn.append( tags.getOpeningTagNonClosingById( JDBC_CONNECTION_DESCRIPTOR ) );
462		strReturn.append( eol );
463		strReturn.append( " " );
464		strReturn.append( tags.getAttribute( JCD_ALIAS, this.getJcdAlias() ) );
465		strReturn.append( eol );
466		strReturn.append( " " );
467		strReturn.append( tags.getAttribute( DEFAULT_CONNECTION, "" + this.isDefaultConnection() ) );
468		strReturn.append( eol );
469		strReturn.append( " " );
470		strReturn.append( tags.getAttribute( DBMS_NAME, this.getDbms() ) );
471		strReturn.append( eol );
472		strReturn.append( " " );
473		strReturn.append( tags.getAttribute( JDBC_LEVEL, "" + this.getJdbcLevel() ) );
474		strReturn.append( eol );
475
476		//username is optional
477		String user = getUserName();
478		if( user != null )
479		{
480		strReturn.append( " " );
481		strReturn.append( tags.getAttribute( USER_NAME, user ) );
482		strReturn.append( eol );
483		}
484		// password is optional
485		String passwd = getPassWord();
486		if( passwd != null )
487		{
488		strReturn.append( " " );
489		strReturn.append( tags.getAttribute( USER_PASSWD, passwd ) );
490		strReturn.append( eol );
491		}
492
493		// JDBC Datasource or DriverManager information are alternatives:
494		String dsn = getDatasourceName();
495		if( dsn != null )
496		{
497		strReturn.append( " " );
498		strReturn.append( tags.getAttribute( DATASOURCE_NAME, this.getDatasourceName() ) );
499		strReturn.append( eol );
500		}
501		else
502		{
503		strReturn.append( " " );
504		strReturn.append( tags.getAttribute( DRIVER_NAME, this.getDriver() ) );
505		strReturn.append( eol );
506		strReturn.append( " " );
507		strReturn.append( tags.getAttribute( URL_PROTOCOL, this.getProtocol() ) );
508		strReturn.append( eol );
509		strReturn.append( " " );
510		strReturn.append( tags.getAttribute( URL_SUBPROTOCOL, this.getSubProtocol() ) );
511		strReturn.append( eol );
512		strReturn.append( " " );
513		strReturn.append( encode( tags.getAttribute( URL_DBALIAS, this.getDbAlias() ) ) );
514		strReturn.append( eol );
515		}
516		strReturn.append( " " );
517		strReturn.append( tags.getAttribute( EAGER_RELEASE, "" + this.getEagerRelease() ) );
518		strReturn.append( eol );
519		strReturn.append( " " );
520		strReturn.append( tags.getAttribute( BATCH_MODE, "" + this.getBatchMode() ) );
521		strReturn.append( eol );
522		strReturn.append( " " );
523		strReturn.append( tags.getAttribute( USE_AUTOCOMMIT, "" + this.getUseAutoCommit() ) );
524		strReturn.append( eol );
525		strReturn.append( " " );
526		strReturn.append( tags.getAttribute( IGNORE_AUTOCOMMIT_EXCEPTION, "" + this.isIgnoreAutoCommitExceptions() ) );
527		strReturn.append( eol );
528
529		strReturn.append( " >" );
530		strReturn.append( eol );
531		strReturn.append( eol );
532
533		strReturn.append( this.getConnectionPoolDescriptor().toXML() );
534		strReturn.append( eol );
535		if( this.getSequenceDescriptor() != null )
536		{
537		strReturn.append( this.getSequenceDescriptor().toXML() );
538		}
539		strReturn.append( eol );
540		strReturn.append( " " );
541		strReturn.append( tags.getClosingTagById( JDBC_CONNECTION_DESCRIPTOR ) );
542		strReturn.append( eol );
543		return strReturn.toString();
544		}
545
546		private static String encode(String toBeEncoded)
547		{
548		StringBuffer retval = new StringBuffer();
549		char c;
550		for (int i=0; i < toBeEncoded.length(); i++)
551		{
552		c = toBeEncoded.charAt(i);
553		if (c == '<')
554		{
555		retval.append("<");
556		}
557		else if (c == '>')
558		{
559		retval.append(">");
560		}
561		//else if (c == '"')
562		//{
563		// retval.append(""");
564		//}
565		else if (c == '&')
566		{
567		retval.append("&");
568		}
569		else if (c == ' ')
570		{
571		retval.append(" ");
572		}
573		else
574		{
575		retval.append(c);
576		}
577		}
578		return retval.toString();
579		}
580
581		private static String getUseAutoCommitAsString(int state)
582		{
583		switch (state)
584		{
585		case AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE:
586		return "AUTO_COMMIT_SET_TRUE_AND_TEMPORARY_FALSE";
587		case AUTO_COMMIT_SET_FALSE:
588		return "AUTO_COMMIT_SET_FALSE";
589		case AUTO_COMMIT_IGNORE_STATE:
590		return "AUTO_COMMIT_IGNORE_STATE";
591		default: return "UNKOWN_STATE";
592		}
593		}
594		}