| commit | author | age | ||
| 7fb4d9 | 1 | package de.uhilger.um; |
| U | 2 | |
| 314fea | 3 | import de.uhilger.baselink.PersistenceManager; |
| U | 4 | import de.uhilger.baselink.Record; |
| 5 | import java.io.BufferedReader; | |
| 6 | import java.io.File; | |
| 7 | import java.io.FileInputStream; | |
| 8 | import java.io.IOException; | |
| 9 | import java.io.InputStream; | |
| 10 | import java.io.InputStreamReader; | |
| 11 | import java.util.List; | |
| 12 | import java.util.Properties; | |
| 13 | import java.util.logging.Level; | |
| 14 | import java.util.logging.Logger; | |
| 15 | import javax.servlet.ServletContext; | |
| 7fb4d9 | 16 | import javax.servlet.ServletContextEvent; |
| U | 17 | import javax.servlet.ServletContextListener; |
| 18 | ||
| 19 | /** | |
| 20 | * Hauptklasse der Anwendung Nutzerverwaltung | |
| 21 | * | |
| 22 | * Hier wird u.a. geprüft, ob die Datenbank vorhanden ist und diese | |
| 23 | * angelegt, falls nicht. | |
| 24 | * | |
| 25 | * @author Ulrich Hilger | |
| 26 | */ | |
| 27 | public class App implements ServletContextListener { | |
| 314fea | 28 | |
| U | 29 | private static final Logger logger = Logger.getLogger(App.class.getName()); |
| 7fb4d9 | 30 | |
| 314fea | 31 | /** Name der Datei mit dem SQL-Skript zum Erzeugen der Datenbank */ |
| U | 32 | private static final String SCRIPT_NAME = "create_database.sql"; |
| 33 | /** Name der Datei mit den SQL-Kommandos dieser Anwendung */ | |
| 34 | public static final String SQL_PROPERTIES_NAME = "sql.properties"; | |
| 35 | /** Name, unter dem das Properties-Objekt mit den SQL-Befehlen im ServletContext hinterlegt ist */ | |
| 36 | public static final String UM_SQL_PROPERTIES = "umSqlProperties"; | |
| 37 | /** Name des Parameters, unter dem der Name der DataSource im Deployment Descritpor zu finden ist */ | |
| 38 | public static final String P_DSNAME = "dsname"; | |
| 39 | ||
| 40 | /** Name des SQL-Befehls zum Pruefen, ob die Datenbank vorhanden ist */ | |
| 41 | public static final String SQL_DB_VORHANDEN = "dbVorhanden"; | |
| 42 | ||
| 43 | ||
| 44 | private static PersistenceManager db; | |
| 45 | private static Properties sql; | |
| 46 | ||
| 47 | /** | |
| 48 | * Ein Eigenschaften-Objekt mit den SQL-Statements initialisieren, | |
| 49 | * die von dieser Webanwendung verwendet werden | |
| 50 | * | |
| 51 | * Die SQL-Kommandos werden aus der Datei | |
| 52 | * [CatalinaBase]/webapps/[Context]/WEB-INF/sql.properties | |
| 53 | * gelesen und als Properties-Objekt unter dem von der Konstante | |
| 54 | * SPOT_SQL_PROPERTIES bezeichneten Namen im ServletContext hinterlegt | |
| 55 | */ | |
| 56 | private void initSql(ServletContext servletContext) { | |
| 57 | try { | |
| 58 | File basis = new File(this.getClass().getResource("/").toURI()); | |
| 59 | File sqlFile = new File(basis.getParentFile(), SQL_PROPERTIES_NAME); | |
| 60 | logger.fine("lese SQL-Eigenschaften von " + sqlFile.getAbsolutePath()); | |
| 61 | sql = new Properties(); | |
| 62 | sql.loadFromXML(new FileInputStream(sqlFile)); | |
| 63 | servletContext.setAttribute(UM_SQL_PROPERTIES, sql); | |
| 64 | logger.fine("Abfrage dbVorhanden='" + sql.getProperty(SQL_DB_VORHANDEN) + "'"); | |
| 65 | } catch(Exception ex) { | |
| 66 | logger.log(Level.SEVERE, ex.getMessage(), ex); | |
| 67 | } | |
| 68 | } | |
| 69 | ||
| 70 | /* ----------------- statische Getter --------------------- */ | |
| 71 | ||
| 72 | /** | |
| 73 | * Das Zugriffsobjekt fuer die Datenbank dieser Webanwendung | |
| 74 | * ermitteln | |
| 75 | * | |
| 76 | * @return das Zugriffsobjekt zur Datenbank dieser Webanwendung | |
| 77 | */ | |
| 78 | public static PersistenceManager getDatabase() { | |
| 79 | if(db == null) { | |
| 80 | db = new PersistenceManager(); | |
| 81 | } | |
| 82 | return db; | |
| 83 | } | |
| 84 | ||
| 85 | public static String getSqlStatement(String id) { | |
| 86 | return sql.getProperty(id); | |
| 87 | } | |
| 88 | ||
| 89 | /* ----------------- Logik zur Datenbank-Erzeugung ------------ */ | |
| 90 | ||
| 91 | /* | |
| 92 | Die Logik zur Datenbank-Erzeugung benoetigt zwei Parameter: | |
| 93 | 1. den Namen der DataSource | |
| 94 | 2. einen SQL-Befehl, mit dem geprueft werden kann, ob die | |
| 95 | Datenbank vorhanden ist | |
| 96 | ||
| 97 | Der Name der DataSource ist im Deployment Descriptor unter dem mit | |
| 98 | P_DSNAME bezeichneten Namen hinterlegt, der SQL-Befehl ist | |
| 99 | im Properties-Objekt mit den SQL-Befehlen dieser Anwendung unter dem | |
| 100 | mit SQL_DB_VORHANDEN bezeichneten Namen zu finden. | |
| 101 | */ | |
| 102 | ||
| 103 | /** | |
| 104 | * Pruefen, ob die von dieser Webanwendung benoetigte Datenbank | |
| 105 | * vorhanden ist. Erzeugen der Datenbank, wenn sie nicht vorgefunden | |
| 106 | * wird. | |
| 107 | * | |
| 108 | * @param servletContext der ServletContext dieser Webanwendung, in dem | |
| 109 | * die Parameter zu finden sind, welche die Datenbankverbindung beschreiben | |
| 110 | */ | |
| 111 | private void initDb(ServletContext servletContext) { | |
| 112 | try { | |
| 113 | db = new PersistenceManager(); | |
| 114 | db.setDataSourceName(servletContext.getInitParameter(P_DSNAME)); | |
| 115 | Properties sql = (Properties) servletContext.getAttribute(UM_SQL_PROPERTIES); | |
| 116 | if(!dbVorhanden(db, sql.getProperty(SQL_DB_VORHANDEN))) { | |
| 117 | logger.info("Datenbank ist nicht vorhanden"); | |
| 118 | int[] ergebnis = db.executeScript(getSqlSkript()); | |
| 119 | } | |
| 120 | } catch(Exception ex) { | |
| 121 | logger.log(Level.INFO, ex.getMessage(), ex); | |
| 122 | } | |
| 123 | } | |
| 124 | ||
| 125 | @SuppressWarnings("rawtypes") | |
| 126 | private boolean dbVorhanden(PersistenceManager pm, String sql) { | |
| 127 | boolean istVorhanden = false; | |
| 128 | List<List<String>> list = pm.select(sql, Record.WITHOUT_BLOBS); | |
| 129 | if(list.size() > 1) { | |
| 130 | istVorhanden = true; | |
| 131 | logger.fine("Datenbank ist vorhanden"); | |
| 132 | } | |
| 133 | return istVorhanden; | |
| 134 | } | |
| 135 | ||
| 136 | private String getSqlSkript() throws Exception { | |
| 137 | File basis = new File(this.getClass().getResource("/").toURI()); | |
| 138 | File skript = new File(basis.getParentFile(), SCRIPT_NAME); | |
| 139 | return fromStream(new FileInputStream(skript)); | |
| 140 | } | |
| 141 | ||
| 142 | private String fromStream(InputStream in) throws IOException | |
| 143 | { | |
| 144 | BufferedReader reader = new BufferedReader(new InputStreamReader(in)); | |
| 145 | StringBuilder out = new StringBuilder(); | |
| 146 | String line; | |
| 147 | while ((line = reader.readLine()) != null) { | |
| 148 | out.append(line); | |
| 149 | } | |
| 150 | return out.toString(); | |
| 151 | } | |
| 152 | ||
| 153 | /* --- ServletContextListener --- */ | |
| 154 | ||
| 7fb4d9 | 155 | @Override |
| U | 156 | public void contextInitialized(ServletContextEvent sce) { |
| 314fea | 157 | ServletContext servletContext = sce.getServletContext(); |
| U | 158 | initSql(servletContext); |
| 159 | initDb(servletContext); | |
| 7fb4d9 | 160 | } |
| U | 161 | |
| 162 | @Override | |
| 163 | public void contextDestroyed(ServletContextEvent sce) { | |
| 164 | // destroy whatever | |
| 165 | } | |
| 166 | ||
| 167 | } | |
