甜橘子，专注成都网站制作网站设计与营销型网站建设与优化
QQ :532337155
电话：028-86922220
开发一个app与后台数据库交互,基于MySQL+jdbc+tomcat,没有使用DBUtils或jdbc框架,纯粹底层jdbc实现.
以后逐步改用Spring框架,优化mysql,进一步部署tomcat等等,现在项目刚刚起步,还有很多不懂的东西,得慢慢来......
这几天踩了很多坑,说得夸张点真是踩到我没有知觉,希望能帮助别人少踩坑...
让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：域名注册、网络空间、营销软件、网站建设、丹凤网站维护、网站推广。
2.github
这是源码地址,包括前后端与建表等所有代码.
(欢迎star)
IDE就不说了,重点说一下mysql与tomcat9的安装
这个是目前比较新的mysql版本.
服务器系统是centos
其他系统安装看这里
centos使用yum命令安装(参考链接)
sudo yum localinstall https://repo.mysql.com//mysql80-community-release-el7-1.noarch.rpmsudo yum install mysql-community-serversudo service mysqld startsudo grep 'temporary password' /var/log/mysqld.logmysql -u root -p输入上一步看到的密码
alter mysql.user 'root'@'localhost' identified by 'password';注意新版本的mysql不能使用太弱的密码
如果出现如下提示
则说明密码太弱了,请使用一个更高强度的密码
use mysql;
update user set host='%' where user='root';这个可以根据自己的需要去修改,host='%'表明允许所有的ip登录,也可以设置特定的ip,若使用host='%'的话建议新建一个用户配置相应的权限.
由于作者使用的是阿里云的服务器,没配置防火墙的话远程连接不上,因此需要手动配置,如图
其中授权对象可以根据自己的需要更改,0.0.0.0/0表示允许所有的ip.
作者使用的是scp命令,不会的可以看这里
scp apache-tomcat-xxxx.tar.gz username@xx.xx.xx.xx:/改成自己的用户名和ip
mkdir /usr/local/tomcat
mv apache-tomcat-xxxx.tar.gz /usr/local/tomcat
tar -xzvf apache-tomcat-xxx.tar.gz修改conf/server.xml文件,一般只需修改
中的8080端口,修改这个端口即可
这个懒的话(比如作者)可以不改
运行bin目录下的startup.sh
cd bin
./startup.sh浏览器输入
服务器IP:端口若出现
则表示成功.
建议配置开机启动,修改/etc/rc.local文件
vim /etc/rc.local
添加
sh /usr/local/tomcat/bin/startup.sh这个根据自己的tomcat安装路径修改,指定bin下的startup.sh即可
创建用户表,这里简化操作(好吧我喜欢偷懒)就不创建新用户不授权了
这是一个在本地用root登录的示例,请根据实际情况创建并授权用户.
CREATE DATABASE userinfo;
USE userinfo;
CREATE TABLE user
(
id INT NOT NULL PRIMARY KEY AUTO_INCREMENT,
name CHAR(30) NULL,
password CHAR(30) NULL
);mysql -u root -p < user.sql
选择web application
选好路径,改好名字后finish
创建一个叫lib的目录
添加两个jar包:
mysql-connector-java-8.0.17.jar
javax.servlet-api-4.0.1.jar
打开Project Structure
Modules--> + --> JARs or directories
选择刚才新建的lib下的两个jar包
打勾,apply
总共4个包
这个是连接数据库的类,纯粹的底层jdbc实现,注意驱动版本.
package com.util;
import java.sql.*;
public class DBUtils {
private static Connection connection = null;
public static Connection getConnection()
{
try {
Class.forName("com.mysql.cj.jdbc.Driver");
String url = "jdbc:mysql://127.0.0.1:3306/数据库名字";
String usename = "账号";
String password = "密码";
connection = DriverManager.getConnection(url,usename,password);
}
catch (Exception e)
{
e.printStackTrace();
return null;
}
return connection;
}
public static void closeConnection()
{
if(connection != null)
{
try {
connection.close();
}
catch (SQLException e)
{
e.printStackTrace();
}
}
}
}主要就是获取连接与关闭连接两个函数.
String url = "jdbc:mysql://127.0.0.1:3306/数据库名字";
String usename = "账号";
String password = "密码";这几行根据自己的用户名,密码,服务器ip和库名修改
注意,mysql8.0以上使用的注册驱动的语句是
Class.forName("com.mysql.cj.jdbc.Driver");旧版的是
Class.forName("com.mysql.jdbc.Driver");注意对应.
User类比较简单,就是就三个字段与getter,setter
package com.entity;
public class User {
private int id;
private String name;
private String password;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}package com.dao;
import com.entity.User;
import com.util.DBUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class UserDao {
public boolean query(User user)
{
Connection connection = DBUtils.getConnection();
String sql = "select * from user where name = ? and password = ?";
try {
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,user.getName());
preparedStatement.setString(2,user.getPassword());
ResultSet resultSet = preparedStatement.executeQuery();
return resultSet.next();
}
catch (SQLException e)
{
e.printStackTrace();
return false;
}
finally {
DBUtils.closeConnection();
}
}
public boolean add(User user)
{
Connection connection = DBUtils.getConnection();
String sql = "insert into user(name,password) values(?,?)";
try {
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1,user.getName());
preparedStatement.setString(2,user.getPassword());
preparedStatement.executeUpdate();
return preparedStatement.getUpdateCount() != 0;
}
catch (SQLException e)
{
e.printStackTrace();
return false;
}
finally {
DBUtils.closeConnection();
}
}
}主要就是查询与添加操作,查询操作中存在该用户就返回true,否则返回false
添加操作中使用executeUpdate()与getUpdateCount() != 0.注意不能直接使用
return preparedStatement.execute();去代替
preparedStatement.executeUpdate();
return preparedStatement.getUpdateCount() != 0;咋一看好像没有什么问题,那天晚上我测试的时候问题可大了,android那边显示注册失败,但是数据库这边的却insert进去了.........我......
好吧说多了都是泪,还是函数用得不够熟练.
所以在这个例子中
return preparedStatement.execute();肯定返回false,所以才会数据库这边insert进去,但前端显示注册失败(这个bug作者找了很久......)
SingIn类用于处理登录,调用jdbc查看数据库是否有对应的用户
SignUp类用于处理注册,把user添加到数据库中
这两个使用的是http连接,后期作者会采用https加密连接.
SignIn.java
package com.servlet;
import com.dao.UserDao;
import com.entity.User;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
@WebServlet("/SignIn")
public class SingIn extends HttpServlet {
@Override
protected void doGet(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse) throws IOException,ServletException
{
this.doPost(httpServletRequest,httpServletResponse);
}
@Override
protected void doPost(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse) throws IOException, ServletException
{
httpServletRequest.setCharacterEncoding("utf-8");
httpServletResponse.setCharacterEncoding("utf-8");
httpServletResponse.setContentType("text/plain;charset=utf-8");//设置相应类型为html,编码为utf-8
String name = httpServletRequest.getParameter("name");
String password = httpServletRequest.getParameter("password");
UserDao userDao = new UserDao();
User user = new User();
user.setName(name);
user.setPassword(password);
if(!userDao.query(user))//若查询失败
{
httpServletResponse.sendError(204,"query failed.");//设置204错误码与出错信息
}
}
}
@WebServlet("/SignIn")这行代码表示这是一个名字叫SignIn的servlet,可用于实现servlet与url的映射,如果不在这里添加这个注解,则需要在WEB-INF目录下的web.xml添加一个
叫servlet的映射
httpServletResponse.setContentType("text/plain;charset=utf-8");//设置相应类型为html,编码为utf-8这行代码设置响应类型与编码
String name = httpServletRequest.getParameter("name");
String password = httpServletRequest.getParameter("password");HttpServletRequest.getParameter(String name)方法表示根据name获取相应的参数
下面是SignUp.java
package com.servlet;
import com.dao.UserDao;
import com.entity.User;
import javax.servlet.annotation.*;
import javax.servlet.http.*;
import javax.servlet.*;
import java.io.IOException;
@WebServlet("/SignUp")
public class SignUp extends HttpServlet {
@Override
protected void doGet(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse) throws IOException,ServletException
{
this.doPost(httpServletRequest,httpServletResponse);
}
@Override
protected void doPost(HttpServletRequest httpServletRequest,HttpServletResponse httpServletResponse) throws IOException,ServletException
{
httpServletRequest.setCharacterEncoding("utf-8");
httpServletResponse.setCharacterEncoding("utf-8");//设定编码防止中文乱码
httpServletResponse.setContentType("text/plain;charset=utf-8");//设置相应类型为html,编码为utf-8
String name = httpServletRequest.getParameter("name");//根据name获取参数
String password = httpServletRequest.getParameter("password");//根据password获取参数
UserDao userDao = new UserDao();
User user = new User();
user.setName(name);
user.setPassword(password);
if(!userDao.add(user)) //若添加失败
{
httpServletResponse.sendError(204,"add failed.");//设置204错误码与出错信息
}
}
}
SignIn
com.servlet.SingIn
SignUp
com.servlet.SignUp
要把刚才创建的Servlet添加进web.xml,在
如果在Servlet类中没有添加
@WebServlet("/xxxx")这个注解,则需要在web.xml中添加
SignIn
/SignIn
其中
Welcome
Hello web.