summaryrefslogtreecommitdiffstats
path: root/sandbox/tutorial-store-www-services/catalog-amazon/store-db/src/main/java/util/CreateDB.java
blob: a4dc2e67e6f342a19a2049e993c646ce3a9512b6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package util;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class CreateDB {

    public static void main(String[] args) {
        System.out.println("Creating database ...");
        
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        
        try {
            //initialize driver and register it with DriverManager
            Class.forName("org.apache.derby.jdbc.EmbeddedDriver");
            
            //connect and create the db if not present
            connection = DriverManager.getConnection(
                    "jdbc:derby:target/store_db;create=true",
                    "",
                    "");
            
            
            try {
                preparedStatement = connection.prepareStatement("DROP TABLE CATALOG");
                preparedStatement.execute();
            }catch(Exception e) {
                //ignore to avoid erros when db is being created from scratch
            }
            
            
            preparedStatement = connection.prepareStatement("CREATE TABLE CATALOG("
                                                            + "id             NUMERIC(5 , 0) NOT NULL,"
                                                            + "product_name   VARCHAR(30),"
                                                            + "currency_code  CHAR(3),"
                                                            + "price          REAL,"
                                                            + "primary key (id)"
                                                            + ")");
            preparedStatement.execute();

            preparedStatement = connection.prepareStatement("INSERT INTO CATALOG VALUES(0,'Apple', 'USD', 2.99)");
            preparedStatement.execute();

            preparedStatement = connection.prepareStatement("INSERT INTO CATALOG VALUES(1,'Orange', 'USD', 3.55)");
            preparedStatement.execute();

            preparedStatement = connection.prepareStatement("INSERT INTO CATALOG VALUES(2,'Pear', 'USD', 1.55)");
            preparedStatement.execute();

            System.out.println("Done !");
            
        } catch (SQLException ex) {         
            ex.printStackTrace();
        }catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        } finally {
            if (preparedStatement!=null) {
                try {
                    preparedStatement.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }

}