Initial commit

Author: mkorszun

Procfile

@@ -0,0 +1 @@
+web:    java -cp target/classes:target/dependency/* com.cloudcontrolled.sample.mysql.App

pom.xml

@@ -0,0 +1,59 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <groupId>com.cloudcontrolled.sample.mysql</groupId>
+  <artifactId>java-mysql-example-app</artifactId>
+  <version>1.0-SNAPSHOT</version>
+  <packaging>jar</packaging>
+    <dependencies>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>5.1.22</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-servlet</artifactId>
+            <version>7.6.0.v20120127</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>servlet-api</artifactId>
+            <version>2.5</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>3.8.1</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <version>2.4</version>
+                <executions>
+                    <execution>
+                        <id>copy-dependencies</id>
+                        <phase>package</phase>
+                        <goals><goal>copy-dependencies</goal></goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>2.3.2</version>
+                <configuration>
+                    <source>1.6</source>
+                    <target>1.6</target>
+                </configuration>
+            </plugin>        
+        </plugins>
+    </build>
+</project>
+

src/main/java/com/cloudcontrolled/sample/mysql/App.java

@@ -0,0 +1,90 @@
+package com.cloudcontrolled.sample.mysql;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.*;
+
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.servlet.*;
+
+public class App {
+
+    private static class Write extends HttpServlet {
+        @Override
+        protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+            Connection connection;
+            try {
+                connection = getConnection();
+                String insert = "INSERT INTO messages (message) VALUES(?)";
+                PreparedStatement stmt = connection.prepareStatement(insert);
+                stmt.setString(1, req.getParameter("message"));
+                stmt.executeUpdate();
+                connection.close();
+            } catch (SQLException e) {
+                throw new ServletException(e);
+            }
+        }
+    }
+
+    private static class Read extends HttpServlet {
+        @Override
+        protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+            Connection connection;
+            PrintWriter out = resp.getWriter();
+            try {
+                connection = getConnection();
+                Statement stmt = connection.createStatement();
+                String select = "SELECT * FROM messages GROUP BY id DESC LIMIT 1";
+                ResultSet rs = stmt.executeQuery(select);
+                if (rs.next()) {
+                    out.print(rs.getString("message"));
+                } else {
+                    out.print("Sorry, no message for you!!!");
+                }
+                out.flush();
+                out.close();
+                connection.close();
+            } catch (SQLException e) {
+                throw new ServletException(e);
+            }
+        }
+    }
+
+    public static void main(String[] args) throws Exception {
+        createSchema();
+        Server server = new Server(Integer.valueOf(System.getenv("PORT")));
+        ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
+        context.setContextPath("/");
+        server.setHandler(context);
+        context.addServlet(new ServletHolder(new Write()), "/write");
+        context.addServlet(new ServletHolder(new Read()), "/read");
+        server.start();
+        server.join();
+    }
+
+    private static void createSchema() throws SQLException {
+        Connection connection = getConnection();
+        Statement stmt = connection.createStatement();
+        stmt.executeUpdate("DROP TABLE IF EXISTS messages");
+        stmt.executeUpdate("CREATE TABLE messages (id INT AUTO_INCREMENT, message VARCHAR(45), PRIMARY KEY (id))");
+        connection.close();
+    }
+
+    protected static Connection getConnection() throws SQLException {
+        String host = System.getenv("MYSQLS_HOSTNAME");
+        String port = System.getenv("MYSQLS_PORT");
+        String database = System.getenv("MYSQLS_DATABASE");
+        String username = System.getenv("MYSQLS_USERNAME");
+        String password = System.getenv("MYSQLS_PASSWORD");
+        String dbUrl = "jdbc:mysql://" + host + ":" + port + "/" +database;
+        return DriverManager.getConnection(dbUrl, username, password);
+    }
+}

src/test/java/com/cloudcontrolled/sample/mysql/AppTest.java

@@ -0,0 +1,38 @@
+package com.cloudcontrolled.sample.mysql;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest 
+    extends TestCase
+{
+    /**
+     * Create the test case
+     *
+     * @param testName name of the test case
+     */
+    public AppTest( String testName )
+    {
+        super( testName );
+    }
+
+    /**
+     * @return the suite of tests being tested
+     */
+    public static Test suite()
+    {
+        return new TestSuite( AppTest.class );
+    }
+
+    /**
+     * Rigourous Test :-)
+     */
+    public void testApp()
+    {
+        assertTrue( true );
+    }
+}