2012-01-27 16 views
3

私はMurachのJava ServletsとJSP 2nd Editionを読んでいます。 彼は.batファイルを通して自動的にインストールされるデータベースを提供します。他に何ができるのか分かりません

私は彼の例を試しましたが、うまくいきました。

私は彼のデータベースを使って私のアプリケーションを作成しようとしていますが、何も起こっていません。ここでは、次のコードは次のとおりです。

JSP:

<%-- 
    Document : index 
    Created on : 27/01/2012, 9:20:02 AM 
    Author  : Camus 
--%> 

<%@page contentType="text/html" pageEncoding="UTF-8"%> 
<!DOCTYPE html> 
<html> 
    <head> 
     <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 
     <title>Form</title> 
    </head> 
    <body> 
     <h1>Type your information here!</h1> 
     <form action="addToEmailList" method="get"> 
      <input type="text" name="firstName">First Name<br> 
      <input type="text" name="lastName"> Last Name<br> 
      <input type="text" name="emailAddress"> email 
      <input type="submit" value="Submit"> 
     </form> 
    </body> 
</html> 

サーブレット

/* 
* To change this template, choose Tools | Templates 
* and open the template in the editor. 
*/ 


import java.sql.*; 
import javax.servlet.*; 
import javax.servlet.http.*; 
import java.io.*; 


/** 
* 
* @author Camus 
*/ 
public class addToEmailList extends HttpServlet { 

    /** 
    * Processes requests for both HTTP <code>GET</code> and <code>POST</code> methods. 
    * @param request servlet request 
    * @param response servlet response 
    * @throws ServletException if a servlet-specific error occurs 
    * @throws IOException if an I/O error occurs 
    */ 
    protected void processRequest(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 

      String firstName = request.getParameter("firstName"); 
      String lastName = request.getParameter("lastName"); 
      String emailAddress = request.getParameter("emailAddress"); 

      User user = new User(); 
      user.setFirstName(firstName); 
      user.setLastName(lastName); 
      user.setEmailAddress(emailAddress); 

      String query ="DELETE FROM user WHERE FirstName = 'Diogo'"; 

      try { 
       String dbURL="jdbc:mysql://localhost:3306/murach"; 
      String username ="root"; 
      String password = "sesame"; 
        Connection connection = DriverManager.getConnection(dbURL, username, password); 

        Statement statement = connection.createStatement(); 
        statement.executeUpdate(query); 
       connection.close(); 
      } 
      catch (Exception e) { 
       e.printStackTrace(); 
     } 


      String URL = "/result.jsp"; 
      RequestDispatcher dispatcher = getServletContext().getRequestDispatcher(URL); 
      dispatcher.forward(request, response); 


    } 

    // <editor-fold defaultstate="collapsed" desc="HttpServlet methods. Click on the + sign on the left to edit the code."> 
    /** 
    * Handles the HTTP <code>GET</code> method. 
    * @param request servlet request 
    * @param response servlet response 
    * @throws ServletException if a servlet-specific error occurs 
    * @throws IOException if an I/O error occurs 
    */ 
    @Override 
    protected void doGet(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
     processRequest(request, response); 
    } 

    /** 
    * Handles the HTTP <code>POST</code> method. 
    * @param request servlet request 
    * @param response servlet response 
    * @throws ServletException if a servlet-specific error occurs 
    * @throws IOException if an I/O error occurs 
    */ 
    @Override 
    protected void doPost(HttpServletRequest request, HttpServletResponse response) 
      throws ServletException, IOException { 
     processRequest(request, response); 
    } 

    /** 
    * Returns a short description of the servlet. 
    * @return a String containing servlet description 
    */ 
    @Override 
    public String getServletInfo() { 
     return "Short description"; 
    }// </editor-fold> 
} 

私はすでに多くのことを試みたと私は何が起こっていないデータベースにチェックインしたとき。私は別のクエリを試して、何も更新されていません。あなたは私が間違っていることを知っていますか?

私を助けてください。私はそれが基本的な間違いであるはずだと思っていますが、私が学んでいるところで、何が起こっているのか本当に分かりません。

ありがとうございます。

答えて

4

なぜフォームを送信するときにDELETEクエリを使用しているのだろうか?私はそれがINSERTであるべきだと思います。

あなたは1つの問題であまりにも多くのことが起こっていると思います。 JSP、サーブレット、データベースについて一度に学びます。あまりにも多くのことが起こっている。

コンピュータサイエンスはすべて分解に関するものです。複雑な問題は、小さくて管理しやすいものに分解して解決します。

データベースを取得するためにサーブレットやJSPは必要ありません。まずそれを働かせてください。

私がお勧めしたいのは、Personクラスから始めることです。そのDAOインタフェースを実装次に

package persistence; 

public interface PersonDao { 
    List<Person> find(String lastName, String firstName); 
    List<Person> find(); 
    void save(Person p); 
    void update(Person p); 
    void delete(Person p); 
} 

package persistence; 

public class PersonDaoImpl implements PersonDao { 
    private Connection connection; 

    public PersonDaoImpl(Connection connection) { 
     this.connection = connection; 
    } 

    // Implement all the JDBC methods here. 
} 

このようなユーティリティクラスはあなたを助けるかもしれない

package model; 

public class Person { 
    private String firstName; 
    private String lastName; 
    private String email; 

// Add constructors, getters, equals, hashcode, etc. 
} 

そして、持続性のためのインタフェースで始まります。それを使用してデータベースに正常に接続し、いくつかの操作を実行できるかどうかを確認してください:

package persistence; 

import java.sql.*; 
import java.util.*; 

/** 
* util.DatabaseUtils 
* User: Michael 
* Date: Aug 17, 2010 
* Time: 7:58:02 PM 
*/ 
public class DatabaseUtils 
{ 
    private static final String DEFAULT_DRIVER = "oracle.jdbc.driver.OracleDriver"; 
    private static final String DEFAULT_URL = "jdbc:oracle:thin:@host:1521:database"; 
    private static final String DEFAULT_USERNAME = "username"; 
    private static final String DEFAULT_PASSWORD = "password"; 
/* 
    private static final String DEFAULT_DRIVER = "org.postgresql.Driver"; 
    private static final String DEFAULT_URL = "jdbc:postgresql://localhost:5432/party"; 
    private static final String DEFAULT_USERNAME = "pgsuper"; 
    private static final String DEFAULT_PASSWORD = "pgsuper"; 
*/ 
/* 
    private static final String DEFAULT_DRIVER = "com.mysql.jdbc.Driver"; 
    private static final String DEFAULT_URL = "jdbc:mysql://localhost:3306/party"; 
    private static final String DEFAULT_USERNAME = "party"; 
    private static final String DEFAULT_PASSWORD = "party"; 
*/ 

    public static void main(String[] args) 
    { 
     long begTime = System.currentTimeMillis(); 

     String driver = ((args.length > 0) ? args[0] : DEFAULT_DRIVER); 
     String url = ((args.length > 1) ? args[1] : DEFAULT_URL); 
     String username = ((args.length > 2) ? args[2] : DEFAULT_USERNAME); 
     String password = ((args.length > 3) ? args[3] : DEFAULT_PASSWORD); 

     Connection connection = null; 

     try 
     { 
      connection = createConnection(driver, url, username, password); 
      DatabaseMetaData meta = connection.getMetaData(); 
      System.out.println(meta.getDatabaseProductName()); 
      System.out.println(meta.getDatabaseProductVersion()); 

      String sqlQuery = "SELECT PERSON_ID, FIRST_NAME, LAST_NAME FROM PERSON ORDER BY LAST_NAME"; 
      System.out.println("before insert: " + query(connection, sqlQuery, Collections.EMPTY_LIST)); 

      connection.setAutoCommit(false); 
      String sqlUpdate = "INSERT INTO PERSON(FIRST_NAME, LAST_NAME) VALUES(?,?)"; 
      List parameters = Arrays.asList("Foo", "Bar"); 
      int numRowsUpdated = update(connection, sqlUpdate, parameters); 
      connection.commit(); 

      System.out.println("# rows inserted: " + numRowsUpdated); 
      System.out.println("after insert: " + query(connection, sqlQuery, Collections.EMPTY_LIST)); 
     } 
     catch (Exception e) 
     { 
      rollback(connection); 
      e.printStackTrace(); 
     } 
     finally 
     { 
      close(connection); 
      long endTime = System.currentTimeMillis(); 
      System.out.println("wall time: " + (endTime - begTime) + " ms"); 
     } 
    } 

    public static Connection createConnection(String driver, String url, String username, String password) throws ClassNotFoundException, SQLException 
    { 
     Class.forName(driver); 

     if ((username == null) || (password == null) || (username.trim().length() == 0) || (password.trim().length() == 0)) 
     { 
      return DriverManager.getConnection(url); 
     } 
     else 
     { 
      return DriverManager.getConnection(url, username, password); 
     } 
    } 

    public static void close(Connection connection) 
    { 
     try 
     { 
      if (connection != null) 
      { 
       connection.close(); 
      } 
     } 
     catch (SQLException e) 
     { 
      e.printStackTrace(); 
     } 
    } 


    public static void close(Statement st) 
    { 
     try 
     { 
      if (st != null) 
      { 
       st.close(); 
      } 
     } 
     catch (SQLException e) 
     { 
      e.printStackTrace(); 
     } 
    } 

    public static void close(ResultSet rs) 
    { 
     try 
     { 
      if (rs != null) 
      { 
       rs.close(); 
      } 
     } 
     catch (SQLException e) 
     { 
      e.printStackTrace(); 
     } 
    } 

    public static void rollback(Connection connection) 
    { 
     try 
     { 
      if (connection != null) 
      { 
       connection.rollback(); 
      } 
     } 
     catch (SQLException e) 
     { 
      e.printStackTrace(); 
     } 
    } 

    public static List<Map<String, Object>> map(ResultSet rs) throws SQLException 
    { 
     List<Map<String, Object>> results = new ArrayList<Map<String, Object>>(); 

     try 
     { 
      if (rs != null) 
      { 
       ResultSetMetaData meta = rs.getMetaData(); 
       int numColumns = meta.getColumnCount(); 
       while (rs.next()) 
       { 
        Map<String, Object> row = new HashMap<String, Object>(); 
        for (int i = 1; i <= numColumns; ++i) 
        { 
         String name = meta.getColumnName(i); 
         Object value = rs.getObject(i); 
         row.put(name, value); 
        } 
        results.add(row); 
       } 
      } 
     } 
     finally 
     { 
      close(rs); 
     } 

     return results; 
    } 

    public static List<Map<String, Object>> query(Connection connection, String sql, List<Object> parameters) throws SQLException 
    { 
     List<Map<String, Object>> results = null; 

     PreparedStatement ps = null; 
     ResultSet rs = null; 

     try 
     { 
      ps = connection.prepareStatement(sql); 

      int i = 0; 
      for (Object parameter : parameters) 
      { 
       ps.setObject(++i, parameter); 
      } 

      rs = ps.executeQuery(); 
      results = map(rs); 
     } 
     finally 
     { 
      close(rs); 
      close(ps); 
     } 

     return results; 
    } 

    public static int update(Connection connection, String sql, List<Object> parameters) throws SQLException 
    { 
     int numRowsUpdated = 0; 

     PreparedStatement ps = null; 

     try 
     { 
      ps = connection.prepareStatement(sql); 

      int i = 0; 
      for (Object parameter : parameters) 
      { 
       ps.setObject(++i, parameter); 
      } 

      numRowsUpdated = ps.executeUpdate(); 
     } 
     finally 
     { 
      close(ps); 
     } 

     return numRowsUpdated; 
    } 
} 
+0

お返事ありがとうございます。私が言ったように私はすべてを試していた。私はDBが更新されているかどうかを確認する最速の方法であるため、このクエリを使用しています。私は最初に選択を試みましたが、どちらもうまくいきませんでした。 – Camus

+0

もう一度ありがとうございます。しかし、私が言ったように私は初心者です。私はあなたがインターフェイスと永続性によって何を意味するのではありません。ありがとう – Camus

+0

学習する時間。永続性とは、「アプリケーションが実行されていなくてもデータを利用できるように、データベースまたはファイルシステムに保存する」という意味です。ランの間に「持続する」。 – duffymo

関連する問題