Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

Source code: javatools/db/util/MySQLDbCreator.java


1   /*
2    * MySQLDbCreator.java
3    *
4    * Created on 25 febbraio 2003, 18.20
5       Javatools (modified version) - Some useful general classes.
6       Copyright (C) 2002-2003  Chris Bitmead (original) Antonio Petrelli (modified)
7   
8       This program is free software; you can redistribute it and/or modify
9       it under the terms of the GNU General Public License as published by
10      the Free Software Foundation; either version 2 of the License, or
11      (at your option) any later version.
12  
13      This program is distributed in the hope that it will be useful,
14      but WITHOUT ANY WARRANTY; without even the implied warranty of
15      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16      GNU General Public License for more details.
17  
18      You should have received a copy of the GNU General Public License
19      along with this program; if not, write to the Free Software
20      Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
21  
22      Contact me at: brenmcguire@users.sourceforge.net
23   */
24  
25  package javatools.db.util;
26  
27  import java.sql.*;
28  import javatools.db.*;
29  import javatools.util.SubstituteVariable;
30  
31  /**
32   *
33   * @author  Antonio Petrelli
34   */
35  public class MySQLDbCreator implements javatools.db.util.DbCreator {
36      
37      public void create(DbDatabase base, String dbAddress, int port, String dbName) throws DbException {
38          DbConnection conn;
39          Connection sqlConn;
40          String sqlString;
41          Statement st;
42          
43          try {
44              conn = base.getNewConnection();
45          }
46          catch (DbException e) {
47              throw e;
48          }
49          sqlString = SubstituteVariable.substitute(base.getProperty("createDatabaseString"), "${dbName}", dbName);
50          try {
51              sqlConn = conn.getSqlConnection();
52              st = sqlConn.createStatement();
53              st.executeUpdate(sqlString);
54              conn.close();
55          }
56          catch (SQLException e) {
57              throw new DbException("Cannot create database");
58          }
59      }
60  }