jahiafilemanagerbaseservice.java

java 写的一个新闻发布系统

        }
        return fmng;
     }

    /**
     * Method getFilemanagerByOwner<br>
     * Return a filemanager
     *
     * @param filemanagerID the filemanager id
     * @return filemanager or null
     *
     */
     public Filemanager getFilemanagerByOwner(int ownerID) {

        Filemanager fmng = new Filemanager();

        if (!fmng.initializeWithOwner(ownerID) ){
            fmng = null;
        }
        return fmng;
     }





   //--------------------------------------------------------------------------
   //
   //
   // File DB Handling Section
   //
   //
   //--------------------------------------------------------------------------


   /**
    * @param the file object to create
    * @return the fileID or -1 on errors
    */
   public int insertFileDB(JahiaFileField aFile) throws JahiaException

   {

        //System.out.println("insertFile(JahiaFileField)");

        int fileID = insertFileDB((JahiaFile)aFile);
        if ( fileID>=0 ){

            Connection dbConn = null;
            Statement stmt = null;

            try {
                // get a connection to the db
                dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

                // execute the query
                String query = " insert into jahia_file_fields (fieldid_jahia_file, fileid_jahia_file, title_file_field)" +
                            " values("
                                    + aFile.getFieldID() + ","
                                    + fileID + ","
                                    + "'" + aFile.getFileFieldTitle()
                                    + "')";


                stmt = dbConn.createStatement();
                debugQuery(query);
                stmt.execute(query);
                aFile.setFileID(fileID);
            }
            catch (SQLException ex) {
                processSQLException("JahiaFilemanagerBaseService::insert()",ex);
                fileID = -1;
            }
            finally
            {
                try {
                    ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
                    if ( stmt != null ) stmt.close();
                } catch ( SQLException ex ) {
                    processSQLException("JahiaFilemanagerBaseService:: insert() freeing connection fails",ex);
                }
            }
        }
        return fileID;
   }


   /**
    * Insert new row in jahia_filemgr_files table
    *
    * @param the file object to create
    * @return the fileID of the new file or -1 on error
    */
   public int insertFileDB(JahiaFile aFile) throws JahiaException

   {
        //System.out.println("insertFile(JahiaFile)");

        int fileID = ServicesRegistry.getInstance().getJahiaIncrementorsDBService().autoIncrement ("jahia_filemgr_files");
        Connection dbConn = null;
        Statement stmt = null;

        try {
            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

            // execute the query
            String query = " insert into jahia_filemgr_files (id_jahia_file, filemgrid_jahia_file, fldid_jahia_file, uploaduser_jahia_file, pageid_jahia_file, is_public_jahia_file, realname_jahia_file, storagename_jahia_file, lastmodifdate_jahia_file, size_jahia_file, type_jahia_file, title_jahia_file, descr_jahia_file)" +
                                " values(" +
                                fileID + "," +
                                aFile.getFilemanagerID() + "," +
                                aFile.getFolderID() + "," +
                                "'" + aFile.getUploadUser() + "'," +
                                aFile.getPageID() + "," +
                                aFile.getPublic() + "," +
                                "'" + JahiaTools.quote(aFile.getRealName()) + "'," +
                                "'" + JahiaTools.quote(aFile.getStorageName()) + "'," +
                                (new Long(aFile.getLastModifDate())).toString() + "," +
                                (new Long(aFile.getSize())).toString() + "," +
                                "'" + JahiaTools.quote(aFile.getType()) + "'," +
                                "'" + JahiaTools.quote(aFile.getTitle()) + "'," +
                                "'" + JahiaTools.quote(aFile.getDescr()) + "')";


            stmt = dbConn.createStatement();
            debugQuery(query);
            stmt.execute(query);
        }
        catch (SQLException ex) {
            processSQLException("JahiaFilemanagerBaseService::insert()",ex);
            fileID = -1;
        }
        finally
        {
            try {
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
                if ( stmt != null ) stmt.close();
            } catch ( SQLException ex ) {
                processSQLException("JahiaFilemanagerBaseService:: insert() freeing connection fails",ex);
            }
        }

        return fileID;
    }


   /**
    * Update a row in jahia_filemgr_files table
    *
    * @param a file object
    * @return true if no exception occurs
    */
   public boolean updateFileDB(JahiaFile aFile)
   {
        boolean success = false;
        Connection dbConn = null;
        Statement stmt = null;

        try {

            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(61);

            // execute the query
            String query = " update jahia_filemgr_files set " +
                                "filemgrid_jahia_file=" + aFile.getFilemanagerID() + "," +
                                "fldid_jahia_file=" + aFile.getFolderID() + "," +
                                "uploaduser_jahia_file='" + aFile.getUploadUser() + "'," +
                                "pageid_jahia_file='" + aFile.getPageID() + "," +
                                "is_public_jahia_file='" + aFile.getPublic() + "," +
                                "realname_jahia_file='" + JahiaTools.quote(aFile.getRealName()) + "'," +
                                "storagename_jahia_file='" + JahiaTools.quote(aFile.getStorageName()) + "'," +
                                "lastmodifdate_jahia_file=" + (new Long(aFile.getLastModifDate())).toString() + "," +
                                "size_jahia_file=" + (new Long(aFile.getSize())).toString() + "," +
                                "type_jahia_file='" + JahiaTools.quote(aFile.getType()) + "'," +
                                "title_jahia_file='" + JahiaTools.quote(aFile.getTitle()) + "'," +
                                "descr_jahia_file='" + JahiaTools.quote(aFile.getDescr()) + "'" +
                                " where id_jahia_file=" + aFile.getFileID();

            stmt = dbConn.createStatement();
            debugQuery(query);
            ServicesRegistry.getInstance().getDBPoolService().executeUpdate(stmt,query);
            success = true;
        }
        catch (SQLException ex) {
            processSQLException("JahiaFilemanagerBaseService::update()",ex);
        }
        finally
        {
            try {
                if ( stmt != null ) stmt.close();
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
            } catch ( SQLException ex ) {
                processSQLException("JahiaFilemanagerBaseService:: update() freeing connection fails",ex);
            }
        }

        return success;

    }


    /**
    * Delete a row in jahia_filemgr_files table
    *
    * @param fileID
    * @return false on any error else true
    */
   public boolean deleteFileDB(int fileID)
   {
        boolean success = false;

        Connection dbConn = null;
        Statement stmt = null;

        try {

            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

            // execute the query
            String query = " delete from jahia_filemgr_files where id_jahia_file=" + fileID;

            stmt = dbConn.createStatement();
            debugQuery(query);
            stmt.execute(query);
            success = true;
        }
        catch (SQLException ex) {
            processSQLException("JahiaFilemanagerBaseService::delete()",ex);
        }
        finally
        {
            try {
                if ( stmt != null ) stmt.close();
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
            } catch ( SQLException ex ) {
                processSQLException("JahiaFilemanagerBaseService:: delete() freeing connection fails",ex);
            }
        }

        return success;

    }


   /**
    * delete all files in a gived folder
    * @param folderID
    * @return the false on error
    */
   public boolean deleteFilesDB(int folderID) throws JahiaException

   {
        boolean success = false;
        Connection dbConn = null;
        Statement stmt = null;

        try {

            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

            // execute the query
            String query = " delete from jahia_filemgr_files where fldid_jahia_file=" + folderID;

            stmt = dbConn.createStatement();
            debugQuery(query);
            ServicesRegistry.getInstance().getDBPoolService().executeUpdate(stmt,query);
            success = true;
        }
        catch (SQLException ex) {
            processSQLException("FolderDB::executeQuery()",ex);
        }
        finally
        {
            try {
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
                if ( stmt != null ) stmt.close();
            } catch ( SQLException ex ) {
                processSQLException("FolderDB::  executeQuery() freeing connection fails",ex);
            }
        }

        return success;
   }


    /**
     * Method getFile
     * Return a file object looking at it's id
     *
     * @param file id
     * @return a file object else null
     */
    public JahiaFile getFileDB(int fileID)
    {

        JahiaFile aFile = null;
        Connection dbConn = null;
        Statement stmt = null;
        ResultSet rs = null;

        try {

            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

            // execute the query
            String query = " select * from jahia_filemgr_files where id_jahia_file=" + fileID;

            stmt = dbConn.createStatement();
            debugQuery(query);
            rs = ServicesRegistry.getInstance().getDBPoolService().executeQuery(stmt,query);
            while ( rs.next() )
            {
                int filemanagerID = rs.getInt("filemgrid_jahia_file");
                int folderID = rs.getInt("fldid_jahia_file");
                String uploadUser = rs.getString("uploaduser_jahia_file");
                int pageID = rs.getInt("pageid_jahia_file");
                int isPublic = rs.getInt("is_public_jahia_file");
                String realName = rs.getString("realname_jahia_file");
                String storageName = rs.getString("storagename_jahia_file");
                long lastModifDate = rs.getLong("lastmodifdate_jahia_file");
                long size = rs.getLong("size_jahia_file");
                String type = rs.getString("type_jahia_file");
                String title = rs.getString("title_jahia_file");
                String descr = rs.getString("descr_jahia_file");

                aFile = new JahiaFile(	filemanagerID,
                                        folderID,
                                        uploadUser,
                                        realName,
                                        storageName,
                                        lastModifDate,
                                        size,
                                        type,
                                        title,
                                        descr	);

                aFile.setFileID(fileID);
                aFile.setPageID(pageID);
                aFile.setPublic(isPublic);
            }
        }
        catch (SQLException ex) {
            processSQLException("JahiaFilemanagerBaseService::getFile(fileID)",ex);
        }
        finally
        {
            try {
                ServicesRegistry.getInstance().getDBPoolService().freeConnection(dbConn);
                if ( rs != null ) rs.close();
                if ( stmt != null ) stmt.close();
            } catch ( SQLException ex ) {
                processSQLException("JahiaFilemanagerBaseService::  getFile(fileID) freeing connection fails",ex);
            }
        }
        return aFile;

    }


    /**
     * Method getFiles
     * Return a Vectors of Files objects depending of a sql where condition
     *
     * @param sqlWhere
     * @return a Vector of Files object else null
     */
    public Vector getFilesDB(String sqlWhere)
    {

        Vector files = new Vector();
        JahiaFile  aFile = null;
        Connection dbConn = null;
        Statement stmt = null;
        ResultSet rs = null;

        try {

            // get a connection to the db
            dbConn = ServicesRegistry.getInstance().getDBPoolService().getConnection(1);

            // execute the query
            String query = " select * from jahia_filemgr_files " + sqlWhere;

            stmt = dbConn.createStatement();
            debugQuery(query);
            rs = ServicesRegistry.getInstance().getDBPoolService().executeQuery(stmt,query);