设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

JavaWeb应用实例:用servlet实现oracle 基本增删改查

2017-3-7 12:51| 发布者: zhangjf| 查看: 1240| 评论: 0

摘要: 很久没有写博客了，可能是太懒散，不愿意把时间花在这上面，可是我心里还是知道写博客的重要性的 ，所以从今天开始 ，我将与大家分享一下我学Java WEB写的一些小实例 ，我个人是不太喜欢书本上的晦涩的概念的，所以 ...

很久没有写博客了，可能是太懒散，不愿意把时间花在这上面，可是我心里还是知道写博客的重要性的 ，所以从今天开始 ，我将与大家分享一下我学Java WEB写的一些小实例 ，我个人是不太喜欢书本上的晦涩的概念的，所以我花了更多的时间在一些应用实例上，我觉得这样的学习方式很适合我，由简到繁，由浅入深

废话不多话，开始我们的第一个实例：

servlet实现Oracle 基本增删改查

开发环境：JDK7 +Myeclipse10+tomcat7.0+oracle 11g

首先附上数据库创建脚本：

  2. create table student(
  3. id VARCHAR2(50) PRIMARY KEY NOT NULL,
  4. name varchar2(50) NOT NULL,
  5. calssGrent varchar2(50) NOT NULL ,
  6. result varchar(12) NOT NULL
  7. );
  8. insert into student(id,name,calssGrent,result) values(perseq.nextval,'张三','33','98')
复制代码

下图为代码结构图和功能演示界面做的比较糟糕 只为实现功能：

MMC_01.Java

页面 //主界面提供添加，修改删除的方法

  2. package org.lsy.servlet;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  6. import java.sql.Connection;
  7. import java.sql.DriverManager;
  8. import java.sql.ResultSet;
  9. import java.sql.Statement;
  11. import javax.servlet.ServletException;
  12. import javax.servlet.http.HttpServlet;
  13. import javax.servlet.http.HttpServletRequest;
  14. import javax.servlet.http.HttpServletResponse;
  16. import oracle.jdbc.oracore.TDSPatch;
  18. public class MMC_01 extends HttpServlet
  19. {
  20. // 驱动程序就是之前在classpath中配置的jdbc的驱动程序的jar包中
  22. // 连接地址是由各个数据库生产商单独提供的，所以需要单独记住
  23. public static final String DBURL = "jdbc:oracle:thin:@localhost:1521:LIUSY";
  24. // 连接数据库的用户名
  25. public static final String DBUSER = "scott";
  26. // 连接数据库的密码
  27. public static final String DBPASS = "tiger";
  29. public void doGet(HttpServletRequest request, HttpServletResponse response)
  30. throws ServletException, IOException
  31. {
  32. //设置请求和响应的编码 ，不然页面上容易出现乱码
  33. request.setCharacterEncoding("UTF-8");
  34. response.setCharacterEncoding("UTF-8");
  36. response.setContentType("text/html;UTF-8");
  37. //输出流
  38. PrintWriter out = response.getWriter();
  39. //数据库连接代码
  40. try
  41. {
  42. Connection conn = null; // 表示数据库的连接的对象
  43. Statement stmt = null; // 表示数据库的更新操作
  44. String sql="insert into student(id,name,calssGrent,result) values('67','刘12宇','33','98')";
  45. System.out.println(sql) ;
  46. // 1、使用Class类加载驱动程序
  47. Class.forName("oracle.jdbc.driver.OracleDriver");
  48. // 2、连接数据库
  49. conn = DriverManager.getConnection(DBURL, DBUSER, DBPASS);
  50. // 3、Statement接口需要通过Connection接口进行实例化操作
  51. stmt = conn.createStatement();
  52. //用 rs获取查询结果 ，这里的SQL语句最好不要用* 我的字段比较少所以就偷一下懒，－，－
  53. ResultSet rs=stmt.executeQuery("select *from student");
  54. out.println("<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">");
  55. out.println("<HTML>");
  56. out.println(" <HEAD><TITLE>A Servlet</TITLE></HEAD>");
  57. out.println(" <BODY>");
  58. //输出表头部分
  59. out.print("<table align='center' border='1'><tr><td>姓名" +
  60. "</td><td>班级</td><td>成绩</td><td>修改</td><td>删除</td></tr>");
  61. while(rs.next())
  62. {
  63. //获取数据库中的ID
  64. String id=rs.getString("id");
  65. //输出一列元素
  66. out.print("<tr><td>"+rs.getString("name")
  67. +"</td><td>"+rs.getString("calssGrent")+"" +
  68. "</td><td>"+rs.getString("result")+"</td>" +
  69. "<td><a href='UpdatePage?id="+id+"'>修改</a></td>" +
  70. "<td><a href='delete?id="+id+"'> 删除 </a></td></tr>");
  72. }
  73. out.println("<td><a href=AddPage>添加数据</a></td>");
  74. out.println(" </BODY>");
  75. out.println("</HTML>");
  76. conn.close();
  78. }
  79. catch (Exception e)
  80. {
  81. e.printStackTrace();
  82. }
  83. out.flush();
  84. out.close();
  85. }
  87. }
复制代码

UpdatePage.java //获取要修改的数据 ，并把修改过的数据提交给Update

  2. package org.lsy.servlet;
  3. import java.io.IOException;
  4. import java.io.PrintWriter;
  5. import java.sql.Connection;
  6. import java.sql.DriverManager;
  7. import java.sql.ResultSet;
  8. import java.sql.Statement;
  10. import javax.servlet.ServletException;
  11. import javax.servlet.http.HttpServlet;
  12. import javax.servlet.http.HttpServletRequest;
  13. import javax.servlet.http.HttpServletResponse;
  15. import com.sun.crypto.provider.RSACipher;
  17. public class UpdatePage extends HttpServlet
  18. {
  19. // 连接地址是由各个数据库生产商单独提供的，所以需要单独记住
  20. public static final String DBURL = "jdbc:oracle:thin:@localhost:1521:LIUSY";
  21. // 连接数据库的用户名
  22. public static final String DBUSER = "scott";
  23. // 连接数据库的密码
  24. public static final String DBPASS = "tiger";
  26. public void doGet(HttpServletRequest request, HttpServletResponse response)
  27. throws ServletException, IOException
  28. {
  29. String id=request.getParameter("id");
  30. //设置请求和响应的编码 ，不然页面上容易出现乱码
  31. request.setCharacterEncoding("UTF-8");
  32. response.setCharacterEncoding("UTF-8");
  33. response.setContentType("text/html;UTF-8");
  34. PrintWriter out = response.getWriter();
  35. try
  36. {
  37. Connection conn = null; // 表示数据库的连接的对象
  38. Statement stmt = null; // 表示数据库的更新操作
  39. // 1、使用Class类加载驱动程序
  40. Class.forName("oracle.jdbc.driver.OracleDriver");
  41. // 2、连接数据库
  42. conn = DriverManager.getConnection(DBURL, DBUSER, DBPASS);
  43. // 3、Statement接口需要通过Connection接口进行实例化操作
  44. stmt = conn.createStatement();
  45. //用 rs获取查询结果 ，这里的SQL语句最好不要用* 我的字段比较少所以就偷一下懒，－，－
  46. ResultSet rs=stmt.executeQuery("select *from student where id='"+id+"'");
  47. while (rs.next())
  48. {
  49. out.println("<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">");
  50. out.println("<HTML>");
  51. out.println(" <HEAD><TITLE>A Servlet</TITLE></HEAD>");
  52. out.println(" <BODY>");
  53. //输入成绩的表单，提交至Update
  54. out.print(" <form action='Update' method='post'> ");
  55. out.print("<table align='center'> <tr><td>姓名：<input type='text' value='"+rs.getString("name")+"'
复制代码
  2. name='name' size=20 ></td></tr>");
  3. out.print("<tr><td>班级：<input type='text' value='"+rs.getString("calssGrent")+"' name='grent' size=20></td></tr>");
  4. out.print("<tr><td>成绩：<input type='text' value='"+rs.getString("result")+"' name='result' size=20></td></tr>");
  5. //为了作为查询数据库的条件 ，这里要把ID传过去
  6. out.print("<input type='hidden' value='"+id+"' name='id'>");
  7. out.print("<tr><td><input type='submit' value='修改'><input type='reset' value='重置'></td></tr></table></form>");
  8. out.print(" </BODY>");
  9. out.println("</HTML>");
  10. }
  11. out.flush();
  12. out.close();
  13. }
  14. catch (Exception e) {
  15. e.printStackTrace();// TODO: handle exception
  16. }
  17. }
  19. }
复制代码

Update.java 接收要修改的数据 ，并更新数据库

  2. package org.lsy.servlet;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  6. import java.sql.Connection;
  7. import java.sql.DriverManager;
  8. import java.sql.Statement;
  10. import javax.servlet.ServletException;
  11. import javax.servlet.http.HttpServlet;
  12. import javax.servlet.http.HttpServletRequest;
  13. import javax.servlet.http.HttpServletResponse;
  15. public class Update extends HttpServlet
  16. {
  17. // 驱动程序就是之前在classpath中配置的jdbc的驱动程序的jar包中
  19. // 连接地址是由各个数据库生产商单独提供的，所以需要单独记住
  20. public static final String DBURL = "jdbc:oracle:thin:@localhost:1521:LIUSY";
  21. // 连接数据库的用户名
  22. public static final String DBUSER = "scott";
  23. // 连接数据库的密码
  24. public static final String DBPASS = "tiger";
  26. public void doGet(HttpServletRequest request, HttpServletResponse response)
  27. throws ServletException, IOException
  28. {
  29. try
  31. {
  32. request.setCharacterEncoding("UTF-8");
  33. response.setCharacterEncoding("UTF-8");
  34. response.setContentType("text/html;UTF-8");
  35. PrintWriter out = response.getWriter();
  36. Connection conn = null; // 表示数据库的连接的对象
  37. Statement stmt = null; // 表示数据库的更新操作
  38. //获取表单提交的参数
  39. String id=request.getParameter("id");
  40. System.out.println(id);
  41. String name=request.getParameter("name");
  42. String grent=request.getParameter("grent");
  43. String result=request.getParameter("result");
  44. //更新SQL
  45. String sqlString="update student set name='"+name+"' ," +
  46. "calssGrent='"+grent+"',result='"+result+"' where id='"+id+"' ";
  47. // 1、使用Class类加载驱动程序
  48. Class.forName("oracle.jdbc.driver.OracleDriver");
  49. // 2、连接数据库
  50. conn = DriverManager.getConnection(DBURL, DBUSER, DBPASS);
  51. // 3、Statement接口需要通过Connection接口进行实例化操作
  52. stmt = conn.createStatement();
  53. int pd=stmt.executeUpdate(sqlString);
  54. if(pd!=0)
  55. {
  56. out.println("<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">");
  57. out.println("<HTML>");
  58. out.println(" <HEAD><TITLE>A Servlet</TITLE></HEAD>");
  59. out.println(" <BODY>");
  60. out.print(" 更新成功<br><a href=MMC_01>查看列表</a> ");
  61. out.println(" </BODY>");
  62. out.println("</HTML>");
  63. }
  64. out.flush();
  65. out.close();
  66. stmt.close();
  67. conn.close();
  68. }
  69. catch (Exception e)
  70. {
  71. // TODO: handle exception
  72. }
  73. }
  74. public void doPost(HttpServletRequest request, HttpServletResponse response)
  75. throws ServletException, IOException
  76. {
  77. doGet(request, response);
  78. }
  80. }
复制代码

addPage .java，添加数据页面

  2. package org.lsy.servlet;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  7. import javax.servlet.ServletException;
  8. import javax.servlet.http.HttpServlet;
  9. import javax.servlet.http.HttpServletRequest;
  10. import javax.servlet.http.HttpServletResponse;
  12. public class AddPage extends HttpServlet
  13. {
  15. public void doGet(HttpServletRequest request, HttpServletResponse response)
  16. throws ServletException, IOException
  17. {
  18. //设置请求和响应的编码 ，不然页面上容易出现乱码
  19. request.setCharacterEncoding("UTF-8");
  20. response.setCharacterEncoding("UTF-8");
  21. response.setContentType("text/html;UTF-8");
  22. PrintWriter out = response.getWriter();
  23. out.println("<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">");
  24. out.println("<HTML>");
  25. out.println(" <HEAD><TITLE>A Servlet</TITLE></HEAD>");
  26. out.println(" <BODY>");
  27. //输入成绩的表单，提交至add
  28. out.print(" <form action='Add' method='post'> ");
  29. out.print("<table align='center'> <tr><td>姓名：<input type='text' name='name' size=20 ></td></tr>");
  30. out.print("<tr><td>班级：<input type='text' name='grent' size=20></td></tr>");
  31. out.print("<tr><td>成绩：<input type='text' name='result' size=20></td></tr>");
  32. out.print("<tr><td><input type='submit' value='添加'><input type='reset' value='重置'></td></tr></table></form>");
  33. out.println("<tr><td><a href=MMC_01>查看列表</a></td></tr>");
  34. out.println(" </BODY>");
  35. out.println("</HTML>");
  36. out.flush();
  37. out.close();
  38. }
  40. }
复制代码

add 接收addpage传来的传，更新数据库

  2. package org.lsy.servlet;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  6. import java.sql.Connection;
  7. import java.sql.DriverManager;
  8. import java.sql.PreparedStatement;
  9. import java.sql.ResultSet;
  10. import java.sql.Statement;
  12. import javax.servlet.ServletException;
  13. import javax.servlet.http.HttpServlet;
  14. import javax.servlet.http.HttpServletRequest;
  15. import javax.servlet.http.HttpServletResponse;
  17. import com.sun.org.apache.xerces.internal.impl.io.UTF8Reader;
  19. import oracle.jdbc.oracore.TDSPatch;
  21. public class Add extends HttpServlet
  22. {
  23. // 驱动程序就是之前在classpath中配置的jdbc的驱动程序的jar包中
  25. // 连接地址是由各个数据库生产商单独提供的，所以需要单独记住
  26. public static final String DBURL = "jdbc:oracle:thin:@localhost:1521:LIUSY";
  27. // 连接数据库的用户名
  28. public static final String DBUSER = "scott";
  29. // 连接数据库的密码
  30. public static final String DBPASS = "tiger";
  32. @Override
  33. protected void doPost(HttpServletRequest req, HttpServletResponse resp)
  34. throws ServletException, IOException
  35. {
  36. // TODO Auto-generated method stub
  37. doGet(req, resp);
  38. }
  40. public void doGet(HttpServletRequest request, HttpServletResponse response)
  41. throws ServletException, IOException
  42. {
  43. //设置请求和响应的编码 ，不然页面上容易出现乱码
  44. request.setCharacterEncoding("UTF-8");
  45. response.setCharacterEncoding("UTF-8");
  47. response.setContentType("text/html;UTF-8");
  48. //输出流
  49. PrintWriter out = response.getWriter();
  50. //数据库连接代码
  51. try
  52. {
  53. Connection conn = null; // 表示数据库的连接的对象
  54. Statement pstmt = null; // 表示数据库的更新操作
  55. String nameString=request.getParameter("name");
  56. String grentString=request.getParameter("grent");
  57. String resultString=request.getParameter("result");
  58. System.out.print(nameString);
  59. String sql="insert into student(id,name,calssGrent,result)
复制代码
  2. values(perseq.nextval,'"+nameString+"','"+grentString+"','"+resultString+"')";
  4. // 1、使用Class类加载驱动程序
  5. Class.forName("oracle.jdbc.driver.OracleDriver");
  6. // 2、连接数据库
  7. conn = DriverManager.getConnection(DBURL, DBUSER, DBPASS);
  8. pstmt=conn.createStatement();
  9. int pd=pstmt.executeUpdate(sql);
  10. if (pd!=0)
  11. {
  12. out.println("添加成功");
  13. out.println("<br><a href=MMC_01>查看列表</a>");
  14. }
  15. conn.close();
  17. }
  18. catch (Exception e)
  19. {
  20. e.printStackTrace();
  21. }
  22. out.flush();
  23. out.close();
  24. }
  26. }
复制代码

web.xml 配置文件

  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <web-app version="2.5"
  4. xmlns="http://java.sun.com/xml/ns/javaee"
  5. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
  7. http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  8. <display-name></display-name>
  9. <welcome-file-list>
  10. <welcome-file>index.jsp</welcome-file>
  11. </welcome-file-list>
  12. <servlet-name>MMC_01</servlet-name>
  13. <servlet-class>org.lsy.servlet.MMC_01</servlet-class>
  14. </servlet>
  15. <servlet>
  16. <servlet-name>delete</servlet-name>
  17. <servlet-class>org.lsy.servlet.delete</servlet-class>
  18. </servlet>
  19. <servlet>
  20. <servlet-name>Add</servlet-name>
  21. <servlet-class>org.lsy.servlet.Add</servlet-class>
  22. </servlet>
  23. <servlet>
  24. <servlet-name>AddPage</servlet-name>
  25. <servlet-class>org.lsy.servlet.AddPage</servlet-class>
  26. </servlet>
  27. <servlet>
  28. <servlet-name>UpdatePage</servlet-name>
  29. <servlet-class>org.lsy.servlet.UpdatePage</servlet-class>
  30. </servlet>
  31. <servlet>
  32. <servlet-name>Update</servlet-name>
  33. <servlet-class>org.lsy.servlet.Update</servlet-class>
  34. </servlet>
  37. <servlet-mapping>
  38. <servlet-name>MMC_01</servlet-name>
  39. <url-pattern>/MMC_01</url-pattern>
  40. </servlet-mapping>
  41. <servlet-mapping>
  42. <servlet-name>delete</servlet-name>
  43. <url-pattern>/delete</url-pattern>
  44. </servlet-mapping>
  45. <servlet-mapping>
  46. <servlet-name>Add</servlet-name>
  47. <url-pattern>/Add</url-pattern>
  48. </servlet-mapping>
  49. <servlet-mapping>
  50. <servlet-name>AddPage</servlet-name>
  51. <url-pattern>/AddPage</url-pattern>
  52. </servlet-mapping>
  53. <servlet-mapping>
  54. <servlet-name>UpdatePage</servlet-name>
  55. <url-pattern>/UpdatePage</url-pattern>
  56. </servlet-mapping>
  57. <servlet-mapping>
  58. <servlet-name>Update</servlet-name>
  59. <url-pattern>/Update</url-pattern>
  60. </servlet-mapping>
  61. </web-app>
复制代码

本人并非老鸟，一直处于学习中，有什么错误的地方还请指证，上面的代码有很多重复的部分，很多不合理的地方 ，比较数据库连接直接暴露于操作servlet中 ，为了看的更直观 ，我就没有更改……

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持程序员之家。

收藏 邀请
上一篇：SSH结合jquery实现三级联动效果下一篇：java导出生成csv文件的方法

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-4 02:43

Copyright 2015-2025 djqfx

返回顶部