skindbmanager.java

java 写的一个新闻发布系统

//
//                                   ____.
//                       __/\ ______|    |__/\.     _______
//            __   .____|    |       \   |    +----+       \
//    _______|  /--|    |    |    -   \  _    |    :    -   \_________
//   \\______: :---|    :    :           |    :    |         \________>
//           |__\---\_____________:______:    :____|____:_____\
//                                      /_____|
//
//                 . . . i n   j a h i a   w e   t r u s t . . .
//
//--------------------------
// PortletsDBManager
//--------------------------
// Jerome Bedat 18.12.2000
//--------------------------

package jahiatemplates.org.jahia.skin_blaster;

import java.sql.*;                              // ResultSet
import java.util.*;                             // Vector
import org.jahia.utils.*;                   // JahiaConsole
import org.jahia.registries.*;              // ServicesRegistry
import org.jahia.exceptions.JahiaException; // Jahia Exceptions
import org.jahia.services.database.*;       // DataBase Services


public class SkinDBManager {

    private static SkinDBManager        theObject = null;


    /**
     * SkinDBManager
     *
     * @author Jerome Bedat
     *
     */
	private SkinDBManager()
	{
	    JahiaConsole.println( "SkinsDBManager", "***** Starting the SkinBlaster DataBase Manager *****" );
	} // end constructor


    /**
     * getInstance
     *
     * @author Jerome Bedat
     *
     */
	public static synchronized SkinDBManager getInstance()
	{
	    if (theObject == null) {
	        theObject = new SkinDBManager();
	    }
	    return theObject;
	} // end getInstance


    /**
     * load_UserSkin
     *
     * @author Jerome Bedat
     *
     */
	public int load_UserSkin( String theUserName )
	throws JahiaException
	{
  		Connection dbConn = null;
  		Statement stmt = null;
  		ResultSet rs = null;
  		int theSkinID = -1;
        
	    try {
	        // opens connection
	        dbConn  = ServicesRegistry.getInstance().getDBPoolService().getConnection();
	        stmt    = dbConn.createStatement();
	        
	        // composes the query
	        String sqlQuery = "SELECT * FROM jahiatemplates_skin WHERE (skin_username='" + theUserName + "')";
	        
	        // executes the query
			rs = ServicesRegistry.getInstance().getDBPoolService().executeQuery( stmt, sqlQuery );
			
			if (rs != null) {
			    while (rs.next()) {
		            theSkinID = rs.getInt("skin_id");
	            }
	        }
	    } catch (SQLException se) {
	        theSkinID = -1;
	        String errorMsg = "Error in load_UserSkin : " + se.getMessage();
	        JahiaConsole.println( "SkinBlaster", errorMsg + " -> BAILING OUT" );
	        throw new JahiaException(   "Cannot load skin data from the database", 
	                                    errorMsg, JahiaException.DATABASE_ERROR, JahiaException.CRITICAL );
	    } finally {
			try {
				ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
				if ( stmt != null ) stmt.close();
				//if ( rs != null ) rs.close();
			} catch ( SQLException ex ) {
			    JahiaException je = new JahiaException(   "Cannot free resources", 
	                                    "load_UserSkin : cannot free resources", 
	                                    JahiaException.DATABASE_ERROR, JahiaException.WARNING );
			}
        }
        if (theSkinID == -1) {
            add_UserSkin(theUserName);
            theSkinID = 1;
        }
        return theSkinID;

    } // end load_UserSkin



    /**
     * update_UserSkin
     *
     * @author Jerome Bedat
     *
     */
    public void update_UserSkin( String theUserName, int theSkinID )
    throws JahiaException
    {
        Connection dbConn = null;
        Statement stmt = null;
        try {
            // opens connection
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection();
            stmt = dbConn.createStatement();
            
            // composes the query
            String sqlQuery = "UPDATE jahiatemplates_skin SET ";            
            sqlQuery += "skin_id = " + theSkinID;
            sqlQuery += " WHERE skin_username = '" + theUserName + "'";

            // executes the query
            ServicesRegistry.getInstance().getDBPoolService().executeUpdate( stmt,sqlQuery );

        }
        // catches error if cannot execute update query
        catch (SQLException se)
        {
            String errorMsg = "Error in update_UserSkin : " + se.getMessage();
            JahiaConsole.println( "SkinBlaster", errorMsg + " -> BAILING OUT" );
            throw new JahiaException(   "Cannot update skin in the database",
                                        errorMsg, JahiaException.DATABASE_ERROR, JahiaException.CRITICAL );
        } finally {
            try {
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
                if ( stmt != null ) stmt.close();
            } catch ( SQLException ex ) {
                JahiaException je = new JahiaException(   "Cannot free resources",
                                        "update_UserSkin : cannot free resources",
                                        JahiaException.DATABASE_ERROR, JahiaException.WARNING );
            }
        }
    } // end update_UserSkin


    /**
     * add_UserSkin
     *
     * @author Jerome Bedat
     *
     */
    public void add_UserSkin( String theUserName )
    throws JahiaException
    {
        Connection dbConn = null;
        Statement stmt = null;
        try {
            // opens connection
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection();
            stmt = dbConn.createStatement();

            // saves definition base
            String sqlQuery = "INSERT INTO jahiatemplates_skin (";
            sqlQuery += "skin_username,";
            sqlQuery += "skin_id) VALUES (";
            sqlQuery += "'" + theUserName + "', 1 )";
            ServicesRegistry.getInstance().getDBPoolService().executeUpdate( stmt,sqlQuery );
        }
        // catches error if cannot execute insert query
        catch (SQLException se)
        {
            String errorMsg = "Error in create_jahiatemplates_skin : " + se.getMessage();
            JahiaConsole.println( "SkinBlaster", errorMsg + " -> BAILING OUT" );
            throw new JahiaException(   "Cannot insert new skin definitions in the database",
                                        errorMsg, JahiaException.DATABASE_ERROR, JahiaException.CRITICAL );

        }
    } // end add_UserSkin


    /**
     * add_UserSkin
     *
     * @author Jerome Bedat
     *
     */
    public void consoleOutput( String errorMsg )
    throws JahiaException
    {
        JahiaConsole.println( "SkinBlaster", errorMsg + " -> BAILING OUT" );
    } // end add_UserSkin

}