西河刘卡车医 发表于 2023-11-5 04:13:54

java serverlets使用数据源连接oracle数据库,并执行查询操作代码

package chap03;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Statement;
import java.util.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javax.sql.DataSource;

/**
* Servlet implementation class GetPersonData
*/
@WebServlet("/GetPersonData")
public class GetPersonData extends HttpServlet {
        private static final long serialVersionUID = 1L;
      
    /**
   * @see HttpServlet#HttpServlet()
   */
    public GetPersonData() {
      super();
      // TODO Auto-generated constructor stub
    }
        /**
       * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
       */
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                // TODO Auto-generated method stub
//                response.getWriter().append("Served at: ").append(request.getContextPath());
                String personName, personPwd;
                request.setCharacterEncoding("gb2312");
      personName = request.getParameter("PersonName").trim();
      personPwd = request.getParameter("PersonPwd").trim();
//      GetResult rp = new GetResult();
      response.setContentType("text/html;charset=gb2312");
      PrintWriter out = response.getWriter();
      out.println("");
      out.println("");
      out.println("用户请求信息");
      out.println("");
      out.println("");
      out.println("Request Headers

");
      out.println("");
      Enumeration enames = request.getHeaderNames();
      while(enames.hasMoreElements()) {
              String name = (String)enames.nextElement();
              String value = request.getHeader(name);
              if((value != null) && (!value.equals(""))){
                      out.println("");
                      out.println("" + name + "");
                      out.println("" + value + "");
                      out.println("");                      
              }
      }
      out.println("");
      out.println("
");
      Connection conn = null;
      PreparedStatement stmt = null;
      ResultSet rs = null;
      try{
//                        Class.forName("oracle.jdbc.driver.OracleDriver");
//                        conn = DriverManager.getConnection(rp.getOracle_url(), rp.getOracle_user(), rp.getOracle_pwd());
              Context initContext = new InitialContext();
              Context envContext= (Context)initContext.lookup("java:/comp/env");
              DataSource ds = (DataSource)envContext.lookup("jdbc/myoraclepool");
              conn = ds.getConnection();
                        if(!conn.isClosed()){
                                System.out.println("�ѳɹ�����ora12c");
                  }
                        String sql = "select * from user_list where user_name = ? and user_password = ?";
            stmt = conn.prepareStatement(sql);
            stmt.setString(1, personName);
            stmt.setString(2, personPwd);
                        rs = stmt.executeQuery();
                        if(rs.next()){
                                out.println("*******************************************************");
                                out.println("
");
                                out.println("UserId:" + rs.getString(1) + "    UserName:" + rs.getString(2) + "    UserPwd:" + rs.getString(3));
                                out.println("
");
                                out.println("*******************************************************");
                                out.println("
");
                                HttpSession session = request.getSession();
                                Integer I = new Integer(1);
                                session.setAttribute("userGrade", I);
                                session.setAttribute("userName", personName);
//                                response.sendRedirect("HelloUser.jsp");
                                stmt.close();
                                rs.close();
                                String sqlAll = "select * from user_list";
                    stmt = conn.prepareStatement(sqlAll);
//                    stmt.setString(1, personPwd);
                                rs = stmt.executeQuery();
                                out.println("");
                                out.println("");
                                out.println("");
                                out.println("用户ID ");
                                out.println("");
                                out.println("");
                                out.println("用户名 ");
                                out.println("");
                                out.println("");
                                out.println("密    码 ");
                                out.println("");
                                out.println("");
                                while(rs.next()){
                                       
                                        out.println("");
                                        out.println("");
                                        out.println(rs.getString(1));
                                        out.println("");
                                        out.println("");
                                        out.println(rs.getString(2));
                                        out.println("");
                                        out.println("");
                                        out.println(rs.getString(3));
                                        out.println("");
                                        out.println("");
                                }
                                out.println("");
                                out.println("分页显示");
                                out.println("
");
                                out.println("联系我们");
                                out.println("
");
                        }
                        else
                                response.sendRedirect("loginfail.jsp");
      }catch(NamingException | SQLException e){
                        e.printStackTrace();
      }finally{
                                try{
                                        if(stmt != null)
                                                stmt.close();                      
                                        if(conn != null){
                          conn.close();
                            System.out.println("已连接ora12c");                        
                        }
                        if(rs != null)
                                rs.close();
                                }
                                catch(SQLException e){
                                        e.printStackTrace();
                                }                     
      }
      out.println("");
      out.println("");
        }
        /**
       * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
       */
        protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                // TODO Auto-generated method stub
                doGet(request, response);
        }
}
https://img2023.cnblogs.com/blog/1643193/202310/1643193-20231017102333857-513192076.jpg
 

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
页: [1]
查看完整版本: java serverlets使用数据源连接oracle数据库,并执行查询操作代码