logdaoimpl.java

STRUTS数据库项目开发宝典

/*
 * 
 * on 06-十月-2005 at 04:15:42
 * 
 * Mail:[e-mail]
 * 
 * visit:www.relaioninfo.com or www.helpsoft.org
 */

package org.helpsoft.helplog.dao_impl_jdo;

import org.helpsoft.helplog.dao.*;
import org.helpsoft.helplog.factory.*;
import java.util.Date;
import org.helpsoft.helplog.dto.*;
import org.helpsoft.helplog.exceptions.*;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.ArrayList;
import javax.jdo.*;
import org.helpsoft.helplog.jdo.*;

public class LogDaoImpl implements LogDao
{
	private PersistenceManager pm;

	/** 
	 * Inserts a new row in the Log table.
	 */
	public LogPk insert(Log dto) throws LogDaoException
	{
		try {
			LogEntity logEntity = new LogEntity();
			logEntity.setLogid( dto.getLogid() );
			logEntity.setLogtypecode( dto.getLogtypecode() );
			logEntity.setTitle( dto.getTitle() );
			logEntity.setContent( dto.getContent() );
			logEntity.setAuthor( dto.getAuthor() );
			logEntity.setDate( dto.getDate() );
			pm.makePersistent( logEntity );
			return dto.createPk();
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Updates a single row in the Log table.
	 */
	public void update(LogPk pk, Log dto) throws LogDaoException
	{
		try {
			// retrieve the instance based on its primary-key
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logid = _logid" );
			_query.declareParameters( "String _logid" );
			Collection _result = (Collection) _query.execute(  new Object[] { pk.getLogid() } );
			Iterator _iter = _result.iterator();
			if (_iter.hasNext()) {
				LogEntity jdo = (LogEntity) _iter.next();
		
				// update the jdo instance with the dto values
				jdo.setLogid( dto.getLogid() );
				jdo.setLogtypecode( dto.getLogtypecode() );
				jdo.setTitle( dto.getTitle() );
				jdo.setContent( dto.getContent() );
				jdo.setAuthor( dto.getAuthor() );
				jdo.setDate( dto.getDate() );
		
			} else {
				// couldn't find the object to update
			}
		
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Deletes a single row in the Log table.
	 */
	public void delete(LogPk pk) throws LogDaoException
	{
		try {
			// retrieve the instance based on its primary-key
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logid = _logid" );
			_query.declareParameters( "String _logid" );
			Collection _result = (Collection) _query.execute(  new Object[] { pk.getLogid() } );
			Iterator _iter = _result.iterator();
			if (_iter.hasNext()) {
				LogEntity jdo = (LogEntity) _iter.next();
		
				// delete the jdo instance
				pm.deletePersistent( jdo );
			} else {
				// couldn't find the object to update
			}
		
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns the rows from the Log table that matches the specified primary-key value.
	 */
	public Log findByPrimaryKey(LogPk pk) throws LogDaoException
	{
		return findByPrimaryKey( pk.getLogid() );
	}

	/** 
	 * Returns all rows from the Log table that match the criteria ''.
	 */
	public Log[] findAll() throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Iterator _iter = _extent.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'logid = :logid'.
	 */
	public Log findByPrimaryKey(String logid) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logid = _logid" );
			_query.declareParameters( "String _logid" );
			Collection _result = (Collection) _query.execute(  new Object[] { logid } );
			Iterator _iter = _result.iterator();
			if (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				return _log;
			}
		
			return null;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'logtypecode = :logtypecode'.
	 */
	public Log[] findByLogtype(String logtypecode) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logtypecode = _logtypecode" );
			_query.declareParameters( "String _logtypecode" );
			Collection _result = (Collection) _query.execute(  new Object[] { logtypecode } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'logid = :logid'.
	 */
	public Log[] findWhereLogidEquals(String logid) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logid = _logid" );
			_query.declareParameters( "String _logid" );
			Collection _result = (Collection) _query.execute(  new Object[] { logid } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'logtypecode = :logtypecode'.
	 */
	public Log[] findWhereLogtypecodeEquals(String logtypecode) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "logtypecode = _logtypecode" );
			_query.declareParameters( "String _logtypecode" );
			Collection _result = (Collection) _query.execute(  new Object[] { logtypecode } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'title = :title'.
	 */
	public Log[] findWhereTitleEquals(String title) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "title = _title" );
			_query.declareParameters( "String _title" );
			Collection _result = (Collection) _query.execute(  new Object[] { title } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'content = :content'.
	 */
	public Log[] findWhereContentEquals(String content) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "content = _content" );
			_query.declareParameters( "String _content" );
			Collection _result = (Collection) _query.execute(  new Object[] { content } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'author = :author'.
	 */
	public Log[] findWhereAuthorEquals(String author) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "author = _author" );
			_query.declareParameters( "String _author" );
			Collection _result = (Collection) _query.execute(  new Object[] { author } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/** 
	 * Returns all rows from the Log table that match the criteria 'date = :date'.
	 */
	public Log[] findWhereDateEquals(Date date) throws LogDaoException
	{
		try {
			Extent _extent = pm.getExtent( LogEntity.class, false);
			Query _query = pm.newQuery( _extent, "date = _date" );
			_query.declareParameters( "Date _date" );
			Collection _result = (Collection) _query.execute(  new Object[] { date } );
			Iterator _iter = _result.iterator();
			List _temp = new ArrayList();
			while (_iter.hasNext()) {
				LogEntity logEntity = (LogEntity) _iter.next();
				Log _log = new Log();
				_log.setLogid( logEntity.getLogid() );
				_log.setLogtypecode( logEntity.getLogtypecode() );
				_log.setTitle( logEntity.getTitle() );
				_log.setContent( logEntity.getContent() );
				_log.setAuthor( logEntity.getAuthor() );
				_log.setDate( logEntity.getDate() );
				_temp.add( _log);
			}
		
			Log _ret[] = new Log[ _temp.size() ];
			_temp.toArray( _ret );
			return _ret;
		}
		catch (JDOException _jdoe) {
			throw new LogDaoException( _jdoe.getMessage() );
		}
		catch (Exception _e) {
			throw new LogDaoException( _e.getMessage() );
		}
		
	}

	/**
	 * Method 'LogDaoImpl'
	 * 
	 * @param pm
	 */
	public LogDaoImpl(final PersistenceManager pm)
	{
		this.pm = pm;
	}

}