The Java database action class demonstrates an example of sharing a of Java connection to a database

  • 2020-04-01 02:43:21
  • OfStack


package org.load.demo;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.loadphp.simple4j.ContentValues;
import com.loadphp.simple4j.DB;
import com.loadphp.simple4j.Utils;
public class MyServlet extends HttpServlet {
 @Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  String action = req.getParameter("action");
  if("show".equalsIgnoreCase(action)) {
   this.findAll(req, resp);
  }else if("del".equalsIgnoreCase(action)) {
   this.del(req, resp);
  }else if("edit".equalsIgnoreCase(action)) {
   this.find(req, resp);
  }else if("update".equalsIgnoreCase(action)) {
   this.update(req, resp);
  }else if("insert".equalsIgnoreCase(action)) {
   this.insert(req, resp);
  }
 }
 @Override
 protected void doPost(HttpServletRequest req, HttpServletResponse resp)
   throws ServletException, IOException {
  this.doGet(req, resp);
 }
 
 private void findAll(final HttpServletRequest req, HttpServletResponse resp) {
//  DB db = this.getDB();
//  List<Map<String, Object>> userList = db.findAll("*");  //  All the query 
//  db.close();
//  req.setAttribute("userList", userList);
//  try {
//   req.getRequestDispatcher("/index.jsp").forward(req, resp);
//  } catch (ServletException e) {
//   e.printStackTrace();
//  } catch (IOException e) {
//   e.printStackTrace();
//  }

  DB db = this.getDB();
  db.findAll(new DB.QueryAllCallback() {
   public void callback(List<Map<String, Object>> list) {
    req.setAttribute("userList", list);
   }
  }, "*");

  try {
   req.getRequestDispatcher("/index.jsp").forward(req, resp);
  } catch (ServletException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }

 private void del(HttpServletRequest req, HttpServletResponse resp) {
  DB db = this.getDB();
  db.where(new ContentValues().put("id", req.getParameter("id"))).del();
  db.close();
  this.findAll(req, resp);
 }

 private void find(final HttpServletRequest req, HttpServletResponse resp) {
  DB db = this.getDB();
//  Map<String, Object> map = db.where(new ContentValues().put("id", req.getParameter("id"))).find(
//    "id", "name", "birthday", "pwd");

  db.find(new DB.QueryCallback() {
   public void callback(Map<String, Object> map) {
    req.setAttribute("user", map);
   }
  }, "id","name","birthday");

  db.close();

  try {
   req.getRequestDispatcher("/edit.jsp").forward(req, resp);
  } catch (ServletException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  }
 }

 private void insert(HttpServletRequest req, HttpServletResponse resp) {
  DB db = this.getDB();
  db.insert(Utils.params2Array(req, 3, "null","user","birth","pwd"));
  db.close();
  this.findAll(req, resp);
 }

 private void update(HttpServletRequest req, HttpServletResponse resp) {
  DB db = this.getDB();
  db.where(new ContentValues().put("id", req.getParameter("id"))).update(
    new ContentValues().put("name", req.getParameter("user"))
      .put("pwd", Utils.md5(req.getParameter("pwd")))
      .put("birthday", req.getParameter("birth")));
  db.close();
  this.findAll(req, resp);
 }

 private DB getDB() {
//  DB.DRIVER = "com.mysql.jdbc.Driver";               // driver
  DB.URI = "jdbc:mysql://localhost:3306/forjava";    // uri
//  DB.USER = "root";                                  // mysql The user name 
//  DB.PWD = "";            // mysql password 
  DB.connect("utf-8");          //Connect to the database and set the encoding
  return DB.init("users");         //Sets the table name of the operation and returns the database operation object
 }
}


Related articles: