在【一步一个脚印】Tomcat+MySQL为自己的APP打造服务器(1)服务器环境搭建中我们搭建了完整的服务器开发环境,但是之前的两篇讨论Servlet 的文章并没有用到 MySQL 数据库,因为仅有的登录验证业务也是模拟的。然而在实际业务中不会有模拟的数据和逻辑,所以数据库是必不可少的。今天我们就来说说 Servlet 中使用 MySQL 数据库的方法。
(好久没更新了,在这里给自己找个借口。最近宁波的天气不是很好,一到周末就下雨,平时也没时间运动运动,感觉关节快生锈了。这几天大出血办了个健身卡,然后又被忽悠着办了3个月的私人教练课。不过专业的就是不一样,比自己玩效果好多了,也科学多了,起码保证受伤的几率小了很多,就是心疼白花花的银子的!不扯淡,不然被大家骂,最后再啰嗦一句,干我们这行的,平时多运动,不然以后各种毛病都出来就晚了)
话入正题,其实 MySQL 用起来还是很简单的,但是基于【一步一个脚印】的原则,我们还是从零开始细细说。
第一部分:MySQL准备
之前我门已经安装好了 MySQL 数据库软件,但是还没有用过。装好 MySQL 你有没有试着玩一玩,有没有发现好像就不会用,都不知道从哪入手,是不是感觉懵逼了?那是因为 MySQL 只提供了命令行方式使用(不敢乱说,我是没有找到图形界面,我见到所有人用的不是命令行就是别的管理软件来操作 MySQL),其实我从一开始用就用的是第三方管理软件,比如Navicat for MySQL(第一篇文章中给的下载链接中也给的是这个并附带了激活码)。Navicat 是不需要安装的,直接将文件夹解压到合适的位置后,打开目录下的 navicat.exe 即可运行,我在文件夹外附加了一个激活码。
打开主界面,空的——在左侧管理区域右键-新建连接:
如下图,
连接名是自己起的名字;
主机名或IP地址是 MySQL 安装的主机地址,如果是本机可以直接用localhost或者127.0.0.1;
端口号是安装 MySQL 时指定的端口号,默认是3306(如果手贱改过&&忘了,可以百度一下MySQL配置文件查看一下);
用户名、密码就是安装MySQL时创建的用户名密码,也可以是添加的用户名密码,这个我们之前说过。
左下角有“连接测试”,记得测试一下:
这样就成功了!
如果遇到下边提示:
1045 - Access denied for user 'xxx'@'localhost'(useing password:YES) :用户名、密码错误;
2005 - Unknown MySQL server host 'localhost'(11004) :主机地址不对;
2001 - Can't connect to MySQL server on 'localhost'(10061) : 端口号有问题,或者 MySQL 服务没开;
特别提醒:连接数据库之前,请一定记得打开 MySQL 服务,资源管理器>服务>MySQL57>右键-开启服务:
OK,连接成功后,新建数据库:
右键,新建数据库,新建表:
表名:table_user_password
表名:table_user_info
简单建两个表,我们来测试一下:
第二部分:Servlet 操作 MySQL
OK!MySQL准备好了,下面我们来从 Servlet 中连接 MySQL。这怎么连?我们肯定没法自己连,还是需要借助 MySQL 的驱动,其实就是一个.jar包。直接上MySQL 官网下载 http://dev.mysql.com/downloads/connector/j/ 下载最靠谱。(不过可能有 MySQL 版本和驱动版本不匹配的问题,我是没有遇到,但是根据经验应该会有这样的问题,所以要是 MySQL 版本太老的话还是更新吧,毕竟新版本修复和优化了不少):
Connector/J 就是 connector for Java 。
文件解压后如图:
用的就是这个.jar文件,复制到 WebContent > WEB-INF > lib 文件夹下,并Add to build Path。接下来就可以直接用了。顺便说一下,docs 目录下有文档可以使用,不会了就去看文档,什么都有,包括下面用到的数据库连接代码。
我们在上次的工程中新建 DBUtil 数据库连接工具类,代码如下:
DBUtil.java:
public class DBUtil {这就是最简单的使用,每次访问数据库时获取一个连接,然后进行读写,比如我们新建一个 RegisterServlet ,用来处理用户注册业务:
// table
public static final String TABLE_PASSWORD = "table_user_password";
public static final String TABLE_USERINFO = "table_user_info";
// connect to MySql database
public static Connection getConnect() {
String url = "jdbc:mysql://localhost:3306/first_mysql_test"; // 数据库的Url
Connection connecter = null;
try {
Class.forName("com.mysql.jdbc.Driver"); // java反射,固定写法
connecter = (Connection) DriverManager.getConnection(url, "root", "581825");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
System.out.println("SQLException: " + e.getMessage());
System.out.println("SQLState: " + e.getSQLState());
System.out.println("VendorError: " + e.getErrorCode());
}
return connecter;
}
}</span>
RegisterServlet.java:
@WebServlet("/RegisterServlet")我们运行工程,浏览器请求
public class RegisterServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public RegisterServlet() {
super();
}
/**
* 由于我们还没有说到POST请求,所以还是用GET来处理,汗颜啊,有点慢
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
String account = request.getParameter("account"); // 从 request 中获取名为 account 的参数的值
String password = request.getParameter("password"); // 从 request 中获取名为 password 的参数的值
System.out.println("account:" + account + "\npassword:" + password); // 打印出来看一看
String resCode = "";
String resMsg = "";
String userId = "";
/* 这里我们做一个最简单的注册逻辑,当然,你的实际业务可以相当复杂 */
try {
Connection connect = DBUtil.getConnect();
Statement statement = (Statement) connect.createStatement(); // Statement可以理解为数据库操作实例,对数据库的所有操作都通过它来实现
ResultSet result;
String sqlQuery = "select * from " + DBUtil.TABLE_PASSWORD + " where userAccount='" + account + "'";
// 查询类操作返回一个ResultSet集合,没有查到结果时ResultSet的长度为0
result = statement.executeQuery(sqlQuery); // 先查询同样的账号(比如手机号)是否存在
if(result.next()){ // 已存在
resCode = "201";
resMsg = "该账号已注册,请使用此账号直接登录或使用其他账号注册";
userId = "";
} else { // 不存在
String sqlInsertPass = "insert into " + DBUtil.TABLE_PASSWORD + "(userAccount,userPassword) values('"+account+"','"+password+"')";
// 更新类操作返回一个int类型的值,代表该操作影响到的行数
int row1 = statement.executeUpdate(sqlInsertPass); // 插入帐号密码
if(row1 == 1){
String sqlQueryId = "select userId from " + DBUtil.TABLE_PASSWORD + " where userAccount='" + account + "'";
ResultSet result2 = statement.executeQuery(sqlQueryId); // 查询新增记录的userId
if(result2.next()){
userId = result2.getInt("userId") + "";
}
String sqlInsertInfo = "insert into " + DBUtil.TABLE_USERINFO + "(userId) values('" + userId + "')";
int row2 = statement.executeUpdate(sqlInsertInfo); // 在用户信息表中插入刚注册的Id
if(row2 == 1){ // 两个表中都插入成功,从业务角度认定为注册成功
resCode = "100";
resMsg = "注册成功";
}
} else {
resCode = "202";
resMsg = "用户信息表插入错误";
userId = "";
}
}
} catch (SQLException e) {
e.printStackTrace();
}
HashMap<String, String> map = new HashMap<>();
map.put("resCode", resCode);
map.put("resMsg", resMsg);
map.put("userId", userId);
response.setContentType("text/html;charset=utf-8"); // 设置响应报文的编码格式
PrintWriter pw = response.getWriter(); // 获取 response 的输出流
pw.println(map.toString()); // 通过输出流把业务逻辑的结果输出
pw.flush();
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
}
}</span>
http://localhost:8080/ServletTest/RegisterServlet?account=17749711231&password=123456,看结果:
注册成功了,我们看一下数据中表(应该两个表中都有数据新建):
为了检验我们的注册逻辑,我们试试把同样的请求再发一遍(按预想,应该是返回注册失败,因为已经有一个同样的账号注册过了):
注册逻辑中包含了对 MySQL 的查询和插入(更新)操作,所以我们以注册业务为例,登录什么的更简单(我们可以直接用账号查询,有结果说明该帐号已经注册过,没有结果则说明该帐号未注册,你可以返回不同的错误代码来告诉客户端;在查询到结果的情况下对比密码是否一致,一样了就登录成功,否则提示密码不匹配,所以只涉及到 Select 操作)。
OK,就这样就可以了,最简单的使用!接下来应该是 POST 了。
水平有限,如有不足甚至错误,敬请各位斧正!_程序猿大人_在此先谢过,睡觉觉啦。
PS:文中代码错误已改正,在此特别感谢 @qq970259858 和 @为了玫瑰v给刺浇水 各位的用心指正!