Coverage Report

Coverage Report - org.melati.poem.PoemTransaction

Classes in this File

Line Coverage

Branch Coverage

Complexity

PoemTransaction

74%

23/31

60%

6/10

2.571

 /*
  * $Source$
  * $Revision$
  *
  * Copyright (C) 2000 William Chesters
  *
  * Part of Melati (http://melati.org), a framework for the rapid
  * development of clean, maintainable web applications.
  *
  * Melati is free software; Permission is granted to copy, distribute
  * and/or modify this software under the terms either:
  *
  * a) the GNU General Public License as published by the Free Software
  *    Foundation; either version 2 of the License, or (at your option)
  *    any later version,
  *
  *    or
  *
  * b) any version of the Melati Software License, as published
  *    at http://melati.org
  *
  * You should have received a copy of the GNU General Public License and
  * the Melati Software License along with this program;
  * if not, write to the Free Software Foundation, Inc.,
  * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA to obtain the
  * GNU General Public License and visit http://melati.org to obtain the
  * Melati Software License.
  *
  * Feel free to contact the Developers of Melati (http://melati.org),
  * if you would like to work out a different arrangement than the options
  * outlined here.  It is our intention to allow Melati to be used by as
  * wide an audience as possible.
  *
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
  *
  * Contact details for copyright holder:
  *
  *     William Chesters <williamc At paneris.org>
  *     http://paneris.org/~williamc
  *     Obrechtstraat 114, 2517VX Den Haag, The Netherlands
  */
 
 package org.melati.poem;
 
 import java.sql.Connection;
 import java.sql.SQLException;
 
 import org.melati.poem.transaction.Transaction;
 
 /**
  * A set of dbms actions, which can be rolled back if necessary.
  */
 public class PoemTransaction extends Transaction {
   private Database database;
   private Connection connection;
 
   /**
    * Constructor.
    */
   public PoemTransaction(Database database, Connection connection, int index) {
     super(database, index);
     this.database = database;
     this.connection = connection;
     try {
       connection.setAutoCommit(false);
     }
     catch (SQLException e) {
       throw new SQLSeriousPoemException(e);
     }
   }
 
   /**
    * @return the Database this PoemTransaction relates to
    */
   public final Database getDatabase() {
     return database;
   }
 
   final Connection getConnection() {
     return connection;
   }
 
   protected void backingCommit() {
     try {
       connection.commit();
       if (database.logCommits()) database.log(new CommitLogEvent(this));
     }
     catch (SQLException e) {
       throw new CommitFailedPoemException(e);
     }
   }
 
   protected void backingRollback() {
     try {
       // MySQL closes idle connections by default
       if(connection.isClosed()){
         if (database.logCommits()) database.log(
               "No rollback on closed connection for " 
                   + new RollbackLogEvent(this));
       } else {
         connection.rollback();
         if (database.logCommits()) database.log(new RollbackLogEvent(this));
       }
     }
     catch (SQLException e) {
       throw new RollbackFailedPoemException(e);
     }
   }
 
   /**
    * Close the transaction, committing or rolling back, 
    * notifying the database that we are closed.
    * @param commit whether to commit before closing
    */
   public void close(boolean commit) {
     try {
       if (commit)
         commit();
       else
         rollback();
     }
     finally {
       database.notifyClosed(this);
     }
   }
 
   /**
    * {@inheritDoc}
    * @see org.melati.poem.transaction.Transaction#toString()
    */
   public String toString() {
     return database.getName() + "/" + super.toString();
   }
 }
 
 

1		/*
2		* $Source$
3		* $Revision$
4		*
5		* Copyright (C) 2000 William Chesters
6		*
7		* Part of Melati (http://melati.org), a framework for the rapid
8		* development of clean, maintainable web applications.
9		*
10		* Melati is free software; Permission is granted to copy, distribute
11		* and/or modify this software under the terms either:
12		*
13		* a) the GNU General Public License as published by the Free Software
14		* Foundation; either version 2 of the License, or (at your option)
15		* any later version,
16		*
17		* or
18		*
19		* b) any version of the Melati Software License, as published
20		* at http://melati.org
21		*
22		* You should have received a copy of the GNU General Public License and
23		* the Melati Software License along with this program;
24		* if not, write to the Free Software Foundation, Inc.,
25		* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA to obtain the
26		* GNU General Public License and visit http://melati.org to obtain the
27		* Melati Software License.
28		*
29		* Feel free to contact the Developers of Melati (http://melati.org),
30		* if you would like to work out a different arrangement than the options
31		* outlined here. It is our intention to allow Melati to be used by as
32		* wide an audience as possible.
33		*
34		* This program is distributed in the hope that it will be useful,
35		* but WITHOUT ANY WARRANTY; without even the implied warranty of
36		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
37		* GNU General Public License for more details.
38		*
39		* Contact details for copyright holder:
40		*
41		* William Chesters <williamc At paneris.org>
42		* http://paneris.org/~williamc
43		* Obrechtstraat 114, 2517VX Den Haag, The Netherlands
44		*/
45
46		package org.melati.poem;
47
48		import java.sql.Connection;
49		import java.sql.SQLException;
50
51		import org.melati.poem.transaction.Transaction;
52
53		/**
54		* A set of dbms actions, which can be rolled back if necessary.
55		*/
56		public class PoemTransaction extends Transaction {
57		private Database database;
58		private Connection connection;
59
60		/**
61		* Constructor.
62		*/
63		public PoemTransaction(Database database, Connection connection, int index) {
64	357	super(database, index);
65	357	this.database = database;
66	357	this.connection = connection;
67		try {
68	357	connection.setAutoCommit(false);
69		}
70	0	catch (SQLException e) {
71	0	throw new SQLSeriousPoemException(e);
72	357	}
73	357	}
74
75		/**
76		* @return the Database this PoemTransaction relates to
77		*/
78		public final Database getDatabase() {
79	43	return database;
80		}
81
82		final Connection getConnection() {
83	12946	return connection;
84		}
85
86		protected void backingCommit() {
87		try {
88	4798	connection.commit();
89	4798	if (database.logCommits()) database.log(new CommitLogEvent(this));
90		}
91	0	catch (SQLException e) {
92	0	throw new CommitFailedPoemException(e);
93	4798	}
94	4798	}
95
96		protected void backingRollback() {
97		try {
98		// MySQL closes idle connections by default
99	13	if(connection.isClosed()){
100	0	if (database.logCommits()) database.log(
101		"No rollback on closed connection for "
102		+ new RollbackLogEvent(this));
103		} else {
104	13	connection.rollback();
105	13	if (database.logCommits()) database.log(new RollbackLogEvent(this));
106		}
107		}
108	0	catch (SQLException e) {
109	0	throw new RollbackFailedPoemException(e);
110	13	}
111	13	}
112
113		/**
114		* Close the transaction, committing or rolling back,
115		* notifying the database that we are closed.
116		* @param commit whether to commit before closing
117		*/
118		public void close(boolean commit) {
119		try {
120	3436	if (commit)
121	3436	commit();
122		else
123	0	rollback();
124		}
125		finally {
126	3436	database.notifyClosed(this);
127	3436	}
128	3436	}
129
130		/**
131		* {@inheritDoc}
132		* @see org.melati.poem.transaction.Transaction#toString()
133		*/
134		public String toString() {
135	2	return database.getName() + "/" + super.toString();
136		}
137		}
138
139