وصول قاعدة بيانات Servlet

هذا الدليل يفترض أنك تعرف كيفية عمل تطبيقات JDBC.

ملاحظة:
عناوين تنزيل مكتبات jar لجميع إصدارات mysql:https://downloads.mysql.com/archives/c-j/
في مشروعات Java، يكفي فقط أن نضيف mysql-connector-java-5.1.39-bin.jar إلى Eclipse لبدء تشغيل مشروع Java.
لكن في مشروعات الويب الخاصة بك في Eclipse، عند تنفيذ Class.forName("com.mysql.jdbc.Driver");، لن يتم البحث عن القيادة. لذا يجب علينا في هذا المثال نسخ mysql-connector-java-5.1.39-bin.jar إلى مجلد lib تحت Tomcat.

من حيث المبادئ الأساسية، لنقم بإنشاء جدول بسيط، ونضيف بعض السجلات إليه.

إنشاء بيانات اختبارية

سنقوم الآن بإنشاء قاعدة بيانات w3codebox في MySQL، وإنشاء جدول websites، بنية الجدول كالتالي:

CREATE TABLE `websites` (
　　مُلخص id int(11) NOT NULL AUTO_INCREMENT,
　　مُلخص name char(20) NOT NULL DEFAULT '' COMMENT 'اسم الموقع',
　　مُلخص url varchar(255) NOT NULL DEFAULT '',
　　مُلخص alexa int(11) NOT NULL DEFAULT '0' COMMENT 'ترتيب Alexa',
　　مُلخص country char(10) NOT NULL DEFAULT '' COMMENT 'البلد',
　　PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=10 DEFAULT CHARSET=utf8;

插入一些数据：

INSERT INTO `websites` VALUES ('1', 'Google', 'https://www.google.cm/', '1', 'USA'), ('2', '淘宝', 'https://www.taobao.com/', '13', 'CN'), ('3', '基础教程网', 'http://ar.oldtoolbag.com', '5892', ''), ('4', '微博', 'http://weibo.com/', '20', 'CN'), ('5', 'Facebook', 'https://www.facebook.com/', '3', 'USA');

数据表显示如下：

访问数据库

下面的示例演示了如何使用 Servlet 访问 w3codebox 数据库。

package com.w3codebox.test;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.*;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
　* Servlet implementation class DatabaseAccess
　*/
@WebServlet("/DatabaseAccess")
public class DatabaseAccess extends HttpServlet {
　　　　private static final long serialVersionUID = 1L;
　　　　//　اسم محرك JDBC و عنوان قاعدة البيانات
　　　　static　final　String　JDBC_DRIVER　=　"com.mysql.jdbc.Driver";　　
　　　　static　final　String　DB_URL　=　"jdbc:mysql://localhost:3306/w3codebox";
　　　　
　　　　//　الاسم المستخدم وكلمة المرور للداتا بيز، يجب تعديلها بناءً على الإعدادات الخاصة بك
　　　　static　final　String　USER　=　"root";
　　　　static　final　String　PASS　=　"123456";　
　　　　/**
　　　　　*　@see　HttpServlet#HttpServlet()
　　　　　*/
　　　　public　DatabaseAccess()　{
　　　　　　　　super();
　　　　　　　　//　TODO　Auto-generated　constructor　stub
　　　　}
　　　　/**
　　　　　*　@see　HttpServlet#doGet(HttpServletRequest　request,　HttpServletResponse　response)
　　　　　*/
　　　　protected　void　doGet(HttpServletRequest　request,　HttpServletResponse　response)　throws　ServletException,　IOException　{
　　　　　　　　Connection　conn　=　null;
　　　　　　　　Statement　stmt　=　null;
　　　　　　　　//　设置响应内容类型
　　　　　　　　response.setContentType("text/html;charset=UTF-8");
　　　　　　　　PrintWriter　out　=　response.getWriter();
　　　　　　　　String　title　=　"Servlet　数据库实例　-　基础教程(oldtoolbag.com)";
　　　　　　　　String　docType　=　"<!DOCTYPE　html>\n";
　　　　　　　　out.println(docType　+
　　　　　　　　"<html>\n"　+
　　　　　　　　"<head><title>"　+　title　+　"</title></head>\n"　+
　　　　　　　　"<body　bgcolor=\"#f0f0f0\">\n"　+
　　　　　　　　"<h1　align=\"center\">"　+　title　+　"</h1>\n");
　　　　　　　　try{
　　　　　　　　　　　　// 注册 JDBC 驱动器
　　　　　　　　　　　　Class.forName("com.mysql.jdbc.Driver");
　　　　　　　　　　　　
　　　　　　　　　　　　// 打开一个连接
　　　　　　　　　　　　conn = DriverManager.getConnection(DB_URL,USER,PASS);
　　　　　　　　　　　　// 执行 SQL 查询
　　　　　　　　　　　　stmt = conn.createStatement();
　　　　　　　　　　　　String sql;
　　　　　　　　　　　　sql = "SELECT id, name, url FROM websites";
　　　　　　　　　　　　ResultSet rs = stmt.executeQuery(sql);
　　　　　　　　　　　　// 展开结果集数据库
　　　　　　　　　　　　while(rs.next()){
　　　　　　　　　　　　　　　　// 通过字段检索
　　　　　　　　　　　　　　　　int id = rs.getInt("id");
　　　　　　　　　　　　　　　　String name = rs.getString("name");
　　　　　　　　　　　　　　　　String url = rs.getString("url");
　　　　
　　　　　　　　　　　　　　　　// 输出数据
　　　　　　　　　　　　　　　　out.println("ID: " + id);
　　　　　　　　　　　　　　　　out.println(", اسم الموقع: " + name);
　　　　　　　　　　　　　　　　out.println(", موقعية الويب: " + url);
　　　　　　　　　　　　　　　　out.println("<br />");
　　　　　　　　　　　　}
　　　　　　　　　　　　out.println("</body></html>");
　　　　　　　　　　　　// 完成后关闭
　　　　　　　　　　　　rs.close();
　　　　　　　　　　　　stmt.close();
　　　　　　　　　　　　conn.close();
　　　　　　　　} catch(SQLException se) {
　　　　　　　　　　　　// 处理 JDBC 错误
　　　　　　　　　　　　se.printStackTrace();
　　　　　　　　} catch(Exception e) {
　　　　　　　　　　　　// 处理 Class.forName 错误
　　　　　　　　　　　　e.printStackTrace();
　　　　　　　　}finally{
　　　　　　　　　　　　// 最后是用于关闭资源的块
　　　　　　　　　　　　try{
　　　　　　　　　　　　　　　　if(stmt!=null)
　　　　　　　　　　　　　　　　stmt.close();
　　　　　　　　　　　　}catch(SQLException se2){
　　　　　　　　　　　　}
　　　　　　　　　　　　try{
　　　　　　　　　　　　　　　　if(conn!=null)
　　　　　　　　　　　　　　　　conn.close();
　　　　　　　　　　　　}catch(SQLException se){
　　　　　　　　　　　　　　　　se.printStackTrace();
　　　　　　　　　　　　}
　　　　　　　　}
　　　　　　　
　　　　}
　　　　/**
　　　　　* @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);
　　　　}
}

الآن دعونا نكتب Servlet السابق ونخلق المدخل التالي في ملف web.xml:

....
　　　　<servlet>
　　　　　　　　<servlet-name>DatabaseAccess</servlet-name>
　　　　　　　　<servlet-class>com.w3codebox.test.DatabaseAccess</servlet-class>
　　　　</servlet>
　　　　<servlet-mapping>
　　　　　　　　<servlet-name>DatabaseAccess</servlet-name>
　　　　　　　　<url-pattern>/TomcatTest/DatabaseAccess</url-pattern>
　　　　</servlet-mapping>
....

الآن ابدأ في استدعاء هذا Servlet، أدخل الرابط: http://localhost:8080/TomcatTest/DatabaseAccess، سيتم عرض النتيجة التالية:

تحميل ملفات Servlet تتبع جلسة Servlet

دليل Servlet

وصول قاعدة بيانات Servlet

إنشاء بيانات اختبارية

访问数据库