maildb.java

手机邮箱撒的方式方式方式的

                final Vector storedMessages = new Vector(recordsNumber);
                while (enumeration.hasNextElement()) {
                    try {
                        id = enumeration.nextRecordId();
                        sizeOfRecord = headerRS.getRecordSize(id);
                        if (sizeOfRecord > data.length) {
                            data = new byte[sizeOfRecord + 100];
                            inputStream = new DataInputStream(new ByteArrayInputStream(data));
                        }
                        headerRS.getRecord(id, data, 0);
                        inputStream.reset(); //read from the beginning
                        MessageHeader header = new MessageHeader(progress.actionInvoker); //create a new header // TODO ALF
                        //read the important information from the stream	
                        header.setRecordID(id);
                        header.setOrgLocation(inputStream.readChar());

                        header.setFrom(inputStream.readUTF());
                        header.setRecipients(inputStream.readUTF());
                        header.setSubject(inputStream.readUTF());
                        header.setBoundary(inputStream.readUTF());
                        header.setMessageID(inputStream.readUTF());
                        header.setIMAPFolder(inputStream.readUTF());
                        header.setAccountID(inputStream.readUTF());
                        header.messageFormat = inputStream.readByte();
                        header.readStatus = inputStream.readByte();
                        header.flagged = inputStream.readBoolean();
                        header.DBStatus = inputStream.readByte();
                        header.sendStatus = inputStream.readByte();
                        header.setSize(inputStream.readInt());
                        header.setTime(inputStream.readLong());
                        // fields for threading
                        header.setThreadingMessageID( loadNullable( inputStream.readUTF() ) );
                        header.setParentID( loadNullable( inputStream.readUTF() ) );
                        int parents = inputStream.readInt();
                        Vector parentIDs = new Vector();
                        for (int i = 0; i < parents; ++i) {
                            parentIDs.addElement(inputStream.readUTF());
                        }
                        header.setParentIDs(parentIDs);

                        bodyPartsCount = inputStream.readByte();
                        //now create a new bodypart and read its information
                        for (byte k = 0; k < bodyPartsCount; k++) {
                            BodyPart bp = new BodyPart(header);
                            bp.loadBodyPart(inputStream);
                            header.addBodyPart(bp);
                        }
                        //change the counter of unread mails of the Inbox and use boxes 
                        if (header.readStatus == MessageHeader.NOT_READ) {
                            MujMail.mujmail.getMailDBManager().changeUnreadMails(this, 1);
                        }

                        storedMessages.addElement(header); //add the header to the appropriate box
                        progress.incActual(1);
                        if (progress.stopped()) {
                            break;
                        }
                    } catch (Exception exp) { //usually its EOFException 
                        exp.printStackTrace();
                        //try another header
                    }
                }
                  if (Algorithm.DEBUG) System.out.println( "DEBUG MailDB.loadHeaders(MailDBTask) -  box name: " + progress.actionInvoker.getName() );
                progress.actionInvoker.setStorage(Algorithm.getAlgorithm().invoke(storedMessages));
                if (inputStream != null) {
                    inputStream.close();
                }
                data = null;
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            throw new MyException(MyException.DB_CANNOT_LOAD_HEADERS);
        } catch (Error er) {
            er.printStackTrace();
            throw new MyException(MyException.SYS_OUT_OF_MEMORY);
        } finally {
            Functions.closeRecordStore(headerRS);
        }
        if (DEBUG) { System.out.println("DEBUG MailDB.loadHeaders() - end - " + dbName);
        }
    }

    private void _deleteMail(MailDBTask progress, MessageHeader header) throws MyException {
        for (byte j = (byte) (header.getBodyPartCount() - 1); j >= 0; --j) {
            BodyPart bp = (BodyPart) header.getBodyPart(j);
            bp.getStorage().deleteContent();
        }

        RecordStore headerRS = null;
        try {
            headerRS = RecordStore.openRecordStore(dbName + "_H", true);
        } catch (Exception ex) {
            throw new MyException(0);
        }

        if (headerRS != null) {
            try {
                headerRS.deleteRecord(header.getRecordID());
            } catch (Exception ex) {
                progress.actionInvoker.report("+" + Lang.get(Lang.ALRT_DELETING) + header.getSubject() + Lang.get(Lang.FAILED) + ": " + ex, SOURCE_FILE);
                throw new MyException(0);
            }
        }

        Functions.closeRecordStore(headerRS);
    }

    //batch mails deleting. 	
    private void _deleteMails(MailDBTask progress) throws MyException {
        progress.actionInvoker.report(Lang.get(Lang.ALRT_DELETING) + progress.actionInvoker.getName(), SOURCE_FILE);
        //lock the container as were gonna to modify it, so owningBox.repaint() and other things will not crash
        final IStorage storage = progress.actionInvoker.storage;
        synchronized (storage) {
            //this silly sorting prevents DB corruption as we markAsDeleted headers with higher record id first
            //it seems like emulator's bad implementation of RMS, not sure if it happens to normal phones as well
            // TODO (Betlista) - uncomment: the code bellow
            //Functions.sort(owningBox.storage, Functions.SRT_ORDER_INC, Functions.SRT_HDR_RECORD_ID);
            final int storageSize = storage.getSize();
            Vector/*<MessageHeader>*/ toDel = new Vector/*<MessageHeader>*/();

            // Collect emails marked as delete
            for (int i = 0; i < storageSize; ++i) {
                MessageHeader header = (MessageHeader) storage.getMessageAt(i);
                if (header.deleted) {
                    toDel.addElement(header);
                }
            }
            
            // Remove emails marked for deletion
            for(Enumeration e = toDel.elements(); e.hasMoreElements();) {
                MessageHeader mh = (MessageHeader)e.nextElement();
                // move to trash
                MujMail.mujmail.getTrash().storeToTrash(mh, Trash.TrashModes.CONDITIONALLY_MOVE_TO_TRASH);                
                // remove mail from database
                _deleteMail(progress, mh);
                  // remove mail from storage
                storage.removeMessage(mh);
                --progress.actionInvoker.deleted;
            }
            
            progress.actionInvoker.resort();// we sorted by recordID before the iteration			
            MujMail.mujmail.getTrash().resort();
        }
    }
    
    private void saveHeader(RecordStore headerRS, final MessageHeader header) throws RecordStoreNotOpenException, RecordStoreException, IOException, Exception {
        ByteArrayOutputStream byteStream;
        DataOutputStream outputStream;
        byteStream = new ByteArrayOutputStream();
        outputStream = new DataOutputStream(byteStream);
        //if it was stored then this is update procedure
        boolean update = header.DBStatus == MessageHeader.STORED;
        if (header.getOrgLocation() == 'X') {
            header.setOrgLocation(dbName.charAt(0));
        }
        outputStream.writeChar(header.getOrgLocation());
        outputStream.writeUTF(header.getFrom());
        outputStream.writeUTF(header.getRecipients());
        outputStream.writeUTF(header.getSubject());
        if (header.getBoundary() == null) {
            header.setBoundary(header.getMessageID());
        }
        outputStream.writeUTF(header.getBoundary());
        outputStream.writeUTF(header.getMessageID());
        outputStream.writeUTF(header.getIMAPFolder());
        outputStream.writeUTF(header.getAccountID());
        outputStream.writeByte(header.messageFormat);
        outputStream.writeByte(header.readStatus);
        outputStream.writeBoolean(header.flagged);
        header.DBStatus = MessageHeader.STORED;
        outputStream.writeByte(header.DBStatus);
        outputStream.writeByte(header.sendStatus);
        outputStream.writeInt(header.getSize());
        outputStream.writeLong(header.getTime());
        // fields for threading
        outputStream.writeUTF(saveNullable(header.getThreadingMessageID()));
        outputStream.writeUTF(saveNullable(header.getParentID()));
        Vector parentIDs = header.getParentIDs(); /*<String>*/
        int parentsCount = parentIDs.size();
        outputStream.writeInt(parentsCount);
        for (int i = 0; i < parentsCount; ++i) {
            // this should not be null
            outputStream.writeUTF(parentIDs.elementAt(i).toString());
        }
        // save also all bodypart headers
        byte size = header.getBodyPartCount();
        if (DEBUG) System.out.println("DEBUG - MailDB.saveHeader() - number of bodyparts " + size);
        outputStream.writeByte(size);
        for (byte j = 0; j < size; j++) {
            header.getBodyPart(j).saveBodyPart(outputStream);
        }
        outputStream.flush();
        /*this code doesnt always work, seems like bad implementation of RMS
        if (update)
        headerRS.setRecord(header.recordID, byteStream.toByteArray(), 0, byteStream.size() );
        else
        header.recordID = headerRS.addRecord( byteStream.toByteArray(), 0, byteStream.size() );
         */
        /*this seems working most of time:**/
        int oldID = header.getRecordID();
        header.setRecordID(headerRS.addRecord(byteStream.toByteArray(), 0, byteStream.size()));
        if (update) {
            try {
                headerRS.deleteRecord(oldID);
            } catch (Exception ignored) {
            }
        }
        outputStream.close();
        byteStream.close();
    }
    
    /**
     * Performs stoppable actions.
     */
    private class MailDBTask extends StoppableBackgroundTask {

        /** The box which invoke action. 
         * Note: Used for error reporting in background tasks.
         */
        private PersistentBox actionInvoker;

        /** Specific action to do */
        private byte runMode;

        /** Select mail to delete (in case single mail delete) */
        private MessageHeader messageHeaderToDelete;
        
        public MailDBTask(PersistentBox actionInvoker, byte runMode) {
            super("Database task " + actionInvoker.getDBFileName() + " MailDBTask " + runMode);
            this.actionInvoker = actionInvoker;
            this.runMode = runMode;
        }
        
        void setMessageHeaderToDelete(MessageHeader messageHeaderToDelete) {
            this.messageHeaderToDelete = messageHeaderToDelete;
        }
        
        
        public void doWork() {
            if (MailDB.DEBUG) System.out.println("Starting MailDBTask");
            busy = true;
            switch (runMode) {
                case RUNMODE_LOAD:
                    try {
                        loadHeaders(this);
                        if (MailDB.DEBUG) System.out.println("MailDBTask.doWork - loadHeaders finnished");
                        actionInvoker.report(Lang.get(Lang.ALRT_LOADING) + actionInvoker.getName() + " " + Lang.get(Lang.SUCCESS), SOURCE_FILE);
                    } catch (MyException ex) {
                        ex.printStackTrace();
                        actionInvoker.report(Lang.get(Lang.ALRT_LOADING) + actionInvoker.getName() + " " + Lang.get(Lang.FAILED) + ": " + ex.getDetails(), SOURCE_FILE);
                    }
                    MujMail.mujmail.getMailDBManager().loadedDB(MailDB.this);
                    if (MailDB.DEBUG) System.out.println("MailDBTask.doWork - loadHeaders after loadedDB");
                    break;


                case RUNMODE_DELETE_ALL_MAILS:
                    if (MailDB.DEBUG) System.out.println("DEBUG MailDBTask.doWork() - starting deleting all mails");
                    try {
                        _deleteMails(this);
                        if (MailDB.DEBUG) System.out.println("DEBUG MailDBTask.doWork() - end deleting all mails");
                        actionInvoker.report(Lang.get(Lang.ALRT_DELETING) + actionInvoker.getName() + " " + Lang.get(Lang.SUCCESS), SOURCE_FILE);
                        if (MailDB.DEBUG) System.out.println("DEBUG MailDBTask.doWork() - success reported");
                    } catch (MyException ex) {
                        actionInvoker.report(Lang.get(Lang.ALRT_DELETING) + actionInvoker.getName() + " " + Lang.get(Lang.FAILED) + ": " + ex.getDetails(), SOURCE_FILE);
                    }
                    break;

                case RUNMODE_DELETE_MAIL:
                    try {
                        System.out.println("MailDB.doWork - starting to delete mail");
                        _deleteMail(this, messageHeaderToDelete);
                        System.out.println("MailDB.doWork - mail succesfully deleted");
                        actionInvoker.report(Lang.get(Lang.ALRT_DELETING) + actionInvoker.getName() + " " + Lang.get(Lang.SUCCESS), SOURCE_FILE);
                    } catch (MyException ex) {
                        actionInvoker.report(Lang.get(Lang.ALRT_DELETING) + actionInvoker.getName() + " " + Lang.get(Lang.FAILED) + ": " + ex.getDetails(), SOURCE_FILE);
                    }
                    break;
            }
            synchronized(notifier) {
                busy = false;
                notifier.notifyAll();
            }
            //dbLoadingTask = null; // Loading task ended
            actionInvoker.repaint();
        }
    }
}