小奋斗 - 轻松学习从此开始!
IT小奋斗群 QQ群:62017228

Tomcat+MySQL为自己的APP打造服务器 Servlet连接MySQL数据库

        在Tomcat+MySQL为自己的APP打造服务器 服务器环境搭建中我们搭建了完整的服务器开发环境,但是之前的两篇讨论Servlet 的文章并没有用到 MySQL 数据库,因为仅有的登录验证业务也是模拟的。然而在实际业务中不会有模拟的数据和逻辑,所以数据库是必不可少的。今天我们就来说说 Servlet 中使用 MySQL 数据库的方法。

        (好久没更新了,在这里给自己找个借口。最近宁波的天气不是很好,一到周末就下雨,平时也没时间运动运动,感觉关节快生锈了。这几天大出血办了个健身卡,然后又被忽悠着办了3个月的私人教练课。不过专业的就是不一样,比自己玩效果好多了,也科学多了,起码保证受伤的几率小了很多,就是心疼白花花的银子的!不扯淡,不然被大家骂,最后再啰嗦一句,干我们这行的,平时多运动,不然以后各种毛病都出来就晚了)

        话入正题,其实 MySQL 用起来还是很简单的,但是基于一步一个脚印的原则,我们还是从零开始细细说。

        第一部分:MySQL准备

        之前我门已经安装好了 MySQL 数据库软件,但是还没有用过。装好 MySQL 你有没有试着玩一玩,有没有发现好像就不会用,都不知道从哪入手,是不是感觉懵逼了?那是因为 MySQL 只提供了命令行方式使用(不敢乱说,我是没有找到图形界面,我见到所有人用的不是命令行就是别的管理软件来操作 MySQL),其实我从一开始用就用的是第三方管理软件,比如Navicat for MySQL(第一篇文章中给的下载链接中也给的是这个并附带了激活码)。Navicat 是不需要安装的,直接将文件夹解压到合适的位置后,打开目录下的 navicat.exe 即可运行,我在文件夹外附加了一个激活码

        Navicat


        打开主界面,空的——在左侧管理区域右键-新建连接

        创建连接

        如下图,

        连接名是自己起的名字;

        主机名或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 {
	// 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 ,用来处理用户注册业务:


        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 了。

我来评几句
登录后评论

已发表评论数(0)