JavaWeb連接數(shù)據(jù)庫MySQL的操作技巧
更新時(shí)間：2017年02月08日 14:21:36 作者：JokerLoveAllen
數(shù)據(jù)庫是編程中重要的一部分，它囊括了數(shù)據(jù)操作，數(shù)據(jù)持久化等各方面。在每一門編程語言中都占有相當(dāng)大的比例。本次，小編以MySQL為例，使用mvc編程思想，給大家講解下javaweb對(duì)數(shù)據(jù)庫的操作
數(shù)據(jù)庫是編程中重要的一部分，它囊括了數(shù)據(jù)操作，數(shù)據(jù)持久化等各方面。在每一門編程語言中都占有相當(dāng)大的比例。
本次，我以MySQL為例，使用MVC編程思想(請(qǐng)參閱我之前的博客)。簡單演示一下JavaWeb對(duì)數(shù)據(jù)庫的操作。
1：我們需要掌握簡單的SQL語句，并且會(huì)簡單操作圖形化的數(shù)據(jù)庫。我們?cè)跀?shù)據(jù)庫建一個(gè)表(Users)可以在里面隨便添加幾條數(shù)據(jù)。
2：接下來，我們獲得驅(qū)動(dòng)并連接到MySQL。
package com.joker.web.db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DBConnection {
private static Connection con = null;
// 驅(qū)動(dòng)程序名
private static String driverName = "com.mysql.jdbc.Driver";
// 數(shù)據(jù)庫用戶名
private static String userName = "root";
// 密碼 1
private static String userPasswd = "*****";
// 數(shù)據(jù)庫名
private static String dbName = "jokertest";
// 聯(lián)結(jié)字符串
private static String url = "jdbc:mysql://localhost/" + dbName + "?user="
+ userName + "&password=" + userPasswd
+ "&useUnicode=true&characterEncoding=gbk";
public static Connection getConnection() {
try {
// 1.驅(qū)動(dòng)
Class.forName(driverName);
// 2. 連接數(shù)據(jù)庫 保持連接
con = DriverManager.getConnection(url);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return con;
}
public static void closeConnection() {
if (con != null) {
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}<span style="font-size:18px;color:#990000;">
</span>
3.寫我們的Dao文件,即對(duì)數(shù)據(jù)庫的增刪改查
package com.joker.web.dao;
import java.sql.*;
import java.util.*;
import com.joker.web.db.DBConnection;
import com.joker.web.entity.User;
public class UserDao {
// 查找所有數(shù)據(jù)，返回List集合
public List<User> selectAll() {
Connection con = DBConnection.getConnection();// 連接數(shù)據(jù)庫 保持連接
Statement stmt;
List<User> list = new ArrayList<User>();
try {
stmt = con.createStatement();// 執(zhí)行SQL語句
ResultSet rs = stmt.executeQuery("SELECT * FROM users");// 查找
// 數(shù)據(jù)返回結(jié)果集
while (rs.next()) {
User user = new User();
user.setId(rs.getInt("id"));
user.setUserName(rs.getString("USER_NAME"));
user.setDisplayName(rs.getString("DISPLAY_NAME"));
user.setPwd(rs.getString("PWD"));
list.add(user);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
DBConnection.closeConnection();
}
return list;
}
// 按條件查找
// where USER_NAME='"+ name + "' and PWD='" + pwd + "'
public User selectWhere(String whereOption) {
Connection con = DBConnection.getConnection();// 連接數(shù)據(jù)庫 保持連接
Statement stmt;
User user = null;
try {
stmt = con.createStatement();// 執(zhí)行SQL語句
String sql = "SELECT * FROM users ";
if (!whereOption.equals("")) {
sql += whereOption;
}
// 查找數(shù)據(jù)返回結(jié)果集
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
user = new User();
user.setUserName(rs.getString("USER_NAME"));
user.setDisplayName(rs.getString("DISPLAY_NAME"));
user.setPwd(rs.getString("PWD"));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
DBConnection.closeConnection();
}
return user;
}
// 新增
public int insert(User user) {
Connection con = DBConnection.getConnection();
PreparedStatement pstmt = null;
String sql = " insert into users(user_name,pwd,display_name) values(?,?,?)";
// 增加用prepareStatement
int count = 0;
try {
pstmt = con.prepareStatement(sql);
pstmt.setString(1, user.getUserName());
pstmt.setString(2, user.getPwd());
pstmt.setString(3, user.getDisplayName());
count = pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
pstmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
DBConnection.closeConnection();
}
return count;
}
// 修改
public int upDate(User user) {
Connection con = DBConnection.getConnection();
PreparedStatement pstmt = null;
String sql = " update users " + " set user_name = ? , " + " pwd = ? , "
+ " display_name= ? " + " where id= ? ";
int count = 0;
try {
pstmt = con.prepareStatement(sql);
pstmt.setString(1, user.getUserName());
pstmt.setString(2, user.getPwd());
pstmt.setString(3, user.getDisplayName());
pstmt.setInt(4, user.getId());
count = pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
pstmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
DBConnection.closeConnection();
}
return count;
}
// 刪除
public int delete(int id) {
Connection con = DBConnection.getConnection();
PreparedStatement pstmt = null;
String sql = " delete from users where id = ?";
int count = 0;
try {
pstmt = con.prepareStatement(sql);
pstmt.setInt(1, id);
count = pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
pstmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
DBConnection.closeConnection();
}
return count;
}
public List<User> selectPage(int from, int rows) {
Connection con = DBConnection.getConnection();// 連接數(shù)據(jù)庫 保持連接
Statement stmt;
List<User> list = new ArrayList<User>();
try {
stmt = con.createStatement();// 執(zhí)行SQL語句
ResultSet rs = stmt.executeQuery("SELECT * FROM users LIMIT "
+ from + "," + rows);
while (rs.next()) {
User user = new User();
user.setId(rs.getInt("id"));
user.setUserName(rs.getString("USER_NAME"));
user.setDisplayName(rs.getString("DISPLAY_NAME"));
user.setPwd(rs.getString("PWD"));
list.add(user);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
DBConnection.closeConnection();
}
return list;
}
// 返回所有數(shù)劇條數(shù)
public int selectCount() {
Connection con = DBConnection.getConnection();// 連接數(shù)據(jù)庫 保持連接
Statement stmt;
int count =0 ;
try {
stmt = con.createStatement();// 執(zhí)行SQL語句
ResultSet rs = stmt.executeQuery("SELECT count(1) count FROM users");
while (rs.next()) {
count = rs.getInt("count");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
DBConnection.closeConnection();
}
return count;
}
}<span style="font-size:18px;color:#990000;">
</span>
4.使用Servlet當(dāng)控制器，在Servlet對(duì)網(wǎng)頁上的數(shù)據(jù)進(jìn)行操作。
package com.joker.web.servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.*;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import com.joker.web.dao.UserDao;
import com.joker.web.entity.User;
public class UserServlet extends HttpServlet {
/**
* Constructor of the object.
*/
public UserServlet() {
super();
}
/**
* Destruction of the servlet. <br>
*/
public void destroy() {
super.destroy(); // Just puts "destroy" string in log
// Put your code here
}
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
this.doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
request.setCharacterEncoding("utf-8");
response.setContentType("text/html;charset=utf-8");
String action = request.getParameter("action");
if (action.equals("select")) {
select(request, response);
} else if (action.equals("update")) {
update(request, response);
} else if (action.equals("add")) {
insert(request, response);
} else if (action.equals("delete")) {
delete(request, response);
}
}
// 新增
private void insert(HttpServletRequest request, HttpServletResponse response)
throws IOException {
String uName = request.getParameter("userName");
String pwd = request.getParameter("user");
String dName = request.getParameter("displayName");
User user = new User();
user.setUserName(uName);
user.setPwd(pwd);
user.setDisplayName(dName);
UserDao uDao = new UserDao();
int affCount = uDao.insert(user);
PrintWriter out = response.getWriter();
// 將受影響數(shù)據(jù)的數(shù)量返回給jsp
out.print(affCount);
}
// 刪除
private void delete(HttpServletRequest request, HttpServletResponse response)
throws IOException {
String[] ids = request.getParameterValues("uid[]");
UserDao ud = new UserDao();
int count = 0;
for (int i = 0; i < ids.length; i++) {
count += ud.delete(Integer.parseInt(ids[i]));
}
PrintWriter out = response.getWriter();
out.print(count);
}
/**
* Initialization of the servlet. <br>
*
* @throws ServletException
* if an error occurs
*/
public void init() throws ServletException {
System.out.println("處室執(zhí)行?。。。。。。。。。。。。。?！");
}
// 查詢
public void select(HttpServletRequest request, HttpServletResponse response)
throws IOException {
String page = request.getParameter("page");
String rows = request.getParameter("rows");
System.out.println("page:" + page + " rows:" + rows);
UserDao ud = new UserDao();
int rowsCount = Integer.parseInt(rows);
int from = (Integer.parseInt(page) - 1) * rowsCount;
List<User> list = ud.selectPage(from, rowsCount);
HashMap<String, Object> map = new HashMap<String, Object>();
map.put("total", ud.selectCount());
map.put("rows", list);
// JSONArray ja = JSONArray.fromObject(list);
JSONObject jo = JSONObject.fromObject(map);// 單條數(shù)據(jù)
PrintWriter out = response.getWriter();
System.out.println(jo.toString());
// 將json數(shù)據(jù)返回給jspData-grid的url。
out.println(jo.toString());
}
// 修改
public void update(HttpServletRequest request, HttpServletResponse response)
throws IOException {
String id = request.getParameter("id");
String uName = request.getParameter("userName");
String pwd = request.getParameter("pwd");
String dName = request.getParameter("displayName");
User user = new User();
user.setId(Integer.parseInt(id));
user.setUserName(uName);
user.setPwd(pwd);
user.setDisplayName(dName);
UserDao uDao = new UserDao();
int affCount = uDao.upDate(user);
PrintWriter out = response.getWriter();
// 將受影響數(shù)據(jù)的數(shù)量返回給jsp
out.print(affCount);
}
}<span style="font-size:18px;color:#990000;">
</span>
5.使用Easy-UI框架，是數(shù)據(jù)庫內(nèi)容在頁面進(jìn)行顯示
<%@ page language="java" import="java.util.*" pageEncoding="utf-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme() + "://"
+ request.getServerName() + ":" + request.getServerPort()
+ path + "/";
%>
<!DOCTYPE HTML>
<html>
<head>
<base href="<%=basePath%>" rel="external nofollow" >
<title>main.jsp</title>
<meta http-equiv="pragma" content="no-cache">
<meta http-equiv="cache-control" content="no-cache">
<link rel="stylesheet" href="CSS/easyui.css" rel="external nofollow" type="text/css"></link>
<link rel="stylesheet" href="CSS/icon.css" rel="external nofollow" type="text/css"></link>
<script type="text/javascript" src="JS/jquery-1.8.2.min.js"></script>
<script type="text/javascript" src="JS/jquery.easyui.min.js"></script>
<script type="text/javascript">
var addFlags = true;
$(function() {
$('#dg')
.datagrid(
{
title : '用戶列表',
url : 'servlet/UserServlet?action=select',
fitColumns : true,/* 自適應(yīng)寬度 */
striped : true,/* 斑馬線效果 */
pagination : true,/* 底部顯示分頁工具欄 */
singleSelect : false,/* 只允許選擇一行 */
rownumbers : true,/* 顯示一個(gè)行號(hào)列 */
ctrlSelect : true,/* 允許使用Ctrl鍵+鼠標(biāo)點(diǎn)擊的方式進(jìn)行多選操作 */
iconCls : 'icon-ok',
checkOnSelect : true,/* 點(diǎn)擊行的時(shí)候該復(fù)選框就會(huì)被選中或取消選中 */
selectOnCheck : true,/* 單擊復(fù)選框?qū)⒂肋h(yuǎn)選擇行 */
pagination : true,
nowrap : true,
rownumbers : true,
collapsible : true,//是否可折疊的
pageSize : 5,//每頁顯示的記錄條數(shù)，默認(rèn)為10
pageList : [ 2, 4 ,5],//可以設(shè)置每頁記錄條數(shù)的列表
toolbar : [
{
text : '查詢',
iconCls : 'icon-search',
handler : function() {
$('#dg').datagrid('reload');
}
},
'-',
{
text : '修改',
iconCls : 'icon-edit',
handler : function() {
alert('幫助按鈕');
}
},
'-',
{
text : '添加',
iconCls : 'icon-add',
handler : function() {
if(addFlags){
$('#dg').datagrid('insertRow',{
index: 0, // 索引從0開始
row: {}
});
var editIndex = 0;
$('#dg').datagrid('selectRow',editIndex)
.datagrid('beginEdit',editIndex);
addFlags = false;
}
/* , $('#dlg').dialog('open')
.dialog('center').dialog(
'setTitle',
'New User');
$('#fm').form('clear') */
}
},
'-',
{ text : '刪除',
iconCls : 'icon-remove',
handler : function() {
$.messager.confirm("信息確認(rèn)","確定刪除嗎?",
function(ret) {
if (ret) {
var row = $("#dg").datagrid("getSelections");
if (row.length == 0) {
$.messager.alert("提示:","請(qǐng)選擇刪除的數(shù)據(jù)");
return;
}
var ids = [];
for ( var i = 0; i < row.length; i++) {
ids.push(row[i].id);
}
$.post("servlet/UserServlet?action=delete",
{uid : ids},
function(data) {
if (data > 0) {
$('#dg').datagrid('reload');
alert("刪除成功");
} else {
alert("刪除失敗");
}
});
}
});
}
} ],
columns : [ [
{
field : 'ck',
checkbox : true,
width : 50,
},
{
field : 'id',
hidden : true,
},
{
field : 'userName',
title : '用戶名',
align : 'center',
editor : 'text',
width : 100
},
{
field : 'pwd',
title : '密碼',
width : 100,
editor : 'text',
align : 'center'
},
{
field : 'displayName',
title : '級(jí)別',
width : 100,
height : 100,
editor : 'text',
align : 'center'
},
{
field : 'option',
title : '操作',
width : 100,
align : 'center',
formatter : function(value, row, index) {
if (row.editing) {
var s = '<a href="javascript:void(0);" rel="external nofollow" rel="external nofollow" style="text-decoration:none" onclick="saverow('
+ index + ')">保存</a>'+' '
+'<a href = "javascript:void(0);" style="text-decoration:none" onclick="canclerow('
+ index + ')">取消</a>';
return s;
} else {
var e = '<a href="javascript:void(0);" rel="external nofollow" rel="external nofollow" style="text-decoration:none" onclick="editrow('
+ index + ')">編輯</a>';
return e;
}
}
} ] ],
onBeforeEdit : function(index, row) {
row.editing = true;
$("#dg").datagrid("refreshRow", index);
},
onAfterEdit : function(index, row) {
row.editing = false;
$("#dg").datagrid("refreshRow", index);
}
});
//設(shè)置分頁控件
var p = $('#dg').datagrid('getPager');
$(p).pagination({
beforePageText : '第',//頁數(shù)文本框前顯示的漢字
afterPageText : '頁 共 {pages} 頁',
displayMsg : '當(dāng)前顯示 {from} - {to} 條記錄 共 {total} 條記錄'
});
});
function editrow(index) {
var row = $("#dg").datagrid("getSelected");
if (row == null) {
alert("請(qǐng)選擇您要編輯的行");
return;
}
$("#dg").datagrid("beginEdit", index);
}
function saverow(index) {
$("#dg").datagrid("endEdit", index);
var row = $("#dg").datagrid("getSelected");
if(addFlags) {
dbSave(row);
} else {
dbAdd(row);
}
addFlags = true;
}
function canclerow(index) {
$("#dg").datagrid("rejectChanges");
$('#dg').datagrid('reload');
addFlags = true;
}
function dbSave(row) {
var name = row.userName;
var uid = row.id;
var pwd = row.pwd;
var dname = row.displayName;
$.post("servlet/UserServlet?action=update", {
id : uid,
userName : name,
pwd : pwd,
displayName : dname
}, function(data) {
if (data == "1") {
alert("修改成功");
} else {
alert("修改失敗");
}
});
alert(row.userName + "-" + row.pwd + "-" + row.displayName);
}
function dbAdd(row) {
var name = row.userName;
var pwd = row.pwd;
var dname = row.displayName;
$.post("servlet/UserServlet?action=add", {
userName : name,
pwd : pwd,
displayName : dname
}, function(data) {
if (data == "1") {
alert("添加成功");
} else {
alert("添加失敗");
}
});
}
</script>
<body>
<%-- ${sessionScope.user.userName}
${sessionScope.user.dislayName} --%>
<table class="easyui-datagrid" id="dg">
</table>
</body>
</html><span style="font-size:18px;color:#990000;">
</span>
6.各個(gè)操作具體圖片:
6.1添加:添加（張三 666 學(xué)生 這條數(shù)據(jù)）默認(rèn)顯示五條數(shù)據(jù)
6.2 刪除剛剛插入的數(shù)據(jù)
6.3 修改數(shù)據(jù)(修改的ID主鍵為10的數(shù)據(jù))
以上所述是小編給大家介紹的JavaWeb連接數(shù)據(jù)庫MySQL的操作技巧，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
您可能感興趣的文章:
- Java連接MySql的詳細(xì)介紹
- java連接mysql數(shù)據(jù)庫亂碼的解決方法
- Java連接MYSQL數(shù)據(jù)庫的實(shí)現(xiàn)步驟
- java連接mysql數(shù)據(jù)庫詳細(xì)步驟解析
- java連接MySQl數(shù)據(jù)庫實(shí)例代碼
- java連接Mysql數(shù)據(jù)庫的工具類
- java連接MySQL數(shù)據(jù)庫實(shí)現(xiàn)代碼
- javaweb中mysql數(shù)據(jù)庫連接步驟方法及其實(shí)例
- java連接mysql數(shù)據(jù)庫的方法
- Java+MySQL前后端連接新手小白教程
相關(guān)文章
這篇文章主要介紹了Java鎖擦除與鎖粗化概念和使用，鎖擦除的主要判定依據(jù)來源于逃逸分析的數(shù)據(jù)支持，如果判斷在一段代碼中，堆上的所有數(shù)據(jù)都不會(huì)逃逸出去從而被其他線程訪問到，那就可以把它們當(dāng)做棧上數(shù)據(jù)對(duì)待，認(rèn)為它們是線程私有的，同步加鎖自然就無須進(jìn)行2023-02-02
Java也提供了一個(gè)byte數(shù)據(jù)類型，并且是基本類型。java byte是做為最小的數(shù)字來處理的，因此它的值域被定義為-128~127，也就是signed byte。下面這篇文章主要給大家介紹了關(guān)于java中byte類型的相關(guān)資料，需要的朋友可以參考下。2017-02-02
java.util.Collections類—emptyList()方法的使用
這篇文章主要介紹了java.util.Collections類—emptyList()方法的使用，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11
Spring Security角色繼承實(shí)現(xiàn)過程解析
這篇文章主要介紹了Spring Security角色繼承實(shí)現(xiàn)過程解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08
一個(gè)詞就可以描述注解，那就是元數(shù)據(jù)，即一種描述數(shù)據(jù)的數(shù)據(jù)。所以，可以說注解就是源代碼的元數(shù)據(jù)。文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04
MyBatis?詳細(xì)講解動(dòng)態(tài)?SQL的使用
動(dòng)態(tài)?SQL?是?MyBatis?的強(qiáng)大特性之一。如果你使用過?JDBC?或其它類似的框架，你應(yīng)該能理解根據(jù)不同條件拼接?SQL?語句有多痛苦，例如拼接時(shí)要確保不能忘記添加必要的空格，還要注意去掉列表最后一個(gè)列名的逗號(hào)。利用動(dòng)態(tài)?SQL，可以徹底擺脫這種痛苦2022-04-04
Java中String和StringBuffer及StringBuilder?有什么區(qū)別
這篇文章主要介紹了Java中String和StringBuffer及StringBuilder?有什么區(qū)別，String?是?Java?語言非?；A(chǔ)和重要的類，更多相關(guān)內(nèi)容需要的小伙伴可以參考下面文章內(nèi)容2022-06-06
淺談SpringCloud?Alibaba和SpringCloud的區(qū)別
這篇文章主要介紹了淺談SpringCloud?Alibaba和SpringCloud的區(qū)別,Spring?Cloud?Netflix框架也屬于Spring?Cloud，但是Netflix并不是由spring來進(jìn)行開發(fā)的,需要的朋友可以參考下2023-05-05
這篇文章主要介紹了idea 使用Maven Helper idea的解決方法,本文給大家介紹的非常詳細(xì)對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2023-07-07
這篇文章主要給大家介紹了關(guān)于使用JAVA命令運(yùn)行JAR包以及日志輸出的相關(guān)資料,文中通過代碼示例介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用java具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-09-09