001 /** 002 * 003 * Copyright 2004 Hiram Chirino 004 * 005 * Licensed under the Apache License, Version 2.0 (the "License"); 006 * you may not use this file except in compliance with the License. 007 * You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 * 017 **/ 018 package org.activemq.store.jdbc; 019 020 /** 021 * Generates the SQL statements that are used by the JDBCAdapter. 022 * 023 * @version $Revision: 1.1 $ 024 */ 025 public interface StatementProvider { 026 027 public String[] getCreateSchemaStatments(); 028 public String[] getDropSchemaStatments(); 029 public String getAddMessageStatment(); 030 public String getUpdateMessageStatment(); 031 public String getRemoveMessageStatment(); 032 public String getFindMessageSequenceIdStatment(); 033 public String getFindMessageStatment(); 034 public String getFindMessageAttributesStatment(); 035 public String getFindMessageAttributesForUpdateStatment(); 036 public String getFindAllMessagesStatment(); 037 public String getFindLastSequenceIdInMsgs(); 038 public String getFindLastSequenceIdInAcks(); 039 public String getAddXidStatment(); 040 public String getRemoveXidStatment(); 041 public String getFindAllXidStatment(); 042 public String getCreateDurableSubStatment(); 043 public String getUpdateDurableSubStatment(); 044 public String getFindDurableSubStatment(); 045 public String getUpdateLastAckOfDurableSub(); 046 public String getFindAllDurableSubMessagesStatment(); 047 public String getRemoveAllMessagesStatment(); 048 public String getRemoveAllSubscriptionsStatment(); 049 public String getDeleteSubscriptionStatment(); 050 public String getDeleteOldMessagesStatment(); 051 public String getFindExpiredMessagesStatment(); 052 public String getDeleteMessageStatement(); 053 public String getSetDeadLetterFlagStatement(); 054 public void setTablePrefix(String tablePrefix); 055 public String getTablePrefix(); 056 }