@[toc]php
开发一个app与后台数据库交互,基于mysql+jdbc+tomcat,没有使用DBUtils或jdbc框架,纯粹底层jdbc实现.
之后逐步改用Spring框架,优化mysql,进一步部署tomcat等等,如今项目刚刚起步,还有不少不懂的东西,得慢慢来......
这几天踩了不少坑,说得夸张点真是踩到我没有知觉,但愿能帮助别人少踩坑...html
2.github
这是源码地址,包括先后端与建表等全部代码.
(欢迎star)前端
IDE就不说了,重点说一下mysql与tomcat9的安装java
这个是目前比较新的mysql版本.mysql
服务器系统是centos
其余系统安装看这里android
centos使用yum命令安装(参考连接)git
sudo yum localinstall https://repo.mysql.com//mysql80-community-release-el7-1.noarch.rpm
sudo yum install mysql-community-server
sudo service mysqld start
sudo grep 'temporary password' /var/log/mysqld.log
mysql -u root -p
输入上一步看到的密码github
alter mysql.user 'root'@'localhost' identified by 'password';
注意新版本的mysql不能使用太弱的密码
若是出现以下提示
则说明密码太弱了,请使用一个更高强度的密码web
use mysql; update user set host='%' where user='root';
这个能够根据本身的须要去修改,host='%'代表容许全部的ip登陆,也能够设置特定的ip,若使用host='%'的话建议新建一个用户配置相应的权限.sql
因为做者使用的是阿里云的服务器,没配置防火墙的话远程链接不上,所以须要手动配置,如图
其中受权对象能够根据本身的须要更改,0.0.0.0/0表示容许全部的ip.
<br><br>
做者使用的是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文件,通常只需修改
<Connector port="8080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" />
中的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进去了.........我......
好吧说多了都是泪,仍是函数用得不够熟练.<br><br>
因此在这个例子中
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-mapping>
叫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错误码与出错信息 } } }
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd" version="4.0"> <servlet> <servlet-name>SignIn</servlet-name> <servlet-class>com.servlet.SingIn</servlet-class> </servlet> <servlet> <servlet-name>SignUp</servlet-name> <servlet-class>com.servlet.SignUp</servlet-class> </servlet> </web-app>
要把刚才建立的Servlet添加进web.xml,在<servlet>中添加子元素<servlet-name>与<servlet-class>
<servlet-name>是Servlet的名字,最好与类名一致.
<servlet-class>是Servlet类的位置.
若是在Servlet类中没有添加
@WebServlet("/xxxx")
这个注解,则须要在web.xml中添加
<servlet-mapping> <servlet-name>SignIn</servlet-name> <url-pattern>/SignIn</url-pattern> </servlet-mapping>
其中<servlet-name>与<servlet>中的子元素<servlet-name>中的值一致
<url-pattern>是访问的路径
<!DOCTYPE html> <head> <meta charset="utf-8"> <title>Welcome</title> </head> <body> Hello web. </body> </html>
<br><br><br>
做者用的是IDEA,Eclipse的打包请看这里
(那个lib文件夹被挡住了.....)
web.xml这个须要在WEB-INF目录里,Hello.html在WEB-INF外面
把打包好的.war文件上传到服务器的tomcat的/webapps目录下的
scp ***.war username@xxx.xxx.xxx.xxx:/usr/local/tomcat/webapps
注意改为本身的webapps目录.
在浏览器输入
服务器IP:端口/项目/Hello.html
做者是在本地上开了tomcat后测试的
package com.cx; import android.os.Bundle; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.Toast; import androidx.appcompat.app.AppCompatActivity; public class MainActivity extends AppCompatActivity { @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); Button signin = (Button) findViewById(R.id.signin); signin.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { String name = ((EditText) findViewById(R.id.etname)).getText().toString(); String password = ((EditText) findViewById(R.id.etpassword)).getText().toString(); if (UserService.signIn(name, password)) runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(MainActivity.this, "登陆成功", Toast.LENGTH_SHORT).show(); } }); else { runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(MainActivity.this, "登陆失败", Toast.LENGTH_SHORT).show(); } }); } } }); Button signup = (Button) findViewById(R.id.signup); signup.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { String name = ((EditText) findViewById(R.id.etname)).getText().toString(); String password = ((EditText) findViewById(R.id.etpassword)).getText().toString(); if (UserService.signUp(name, password)) runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(MainActivity.this, "注册成功", Toast.LENGTH_SHORT).show(); } }); else { runOnUiThread(new Runnable() { @Override public void run() { Toast.makeText(MainActivity.this, "注册失败", Toast.LENGTH_SHORT).show(); } }); } } }); } }
没什么好说的,就为两个Button绑定事件,而后设置两个Toast提示信息.
package com.cx; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; public class UserService { public static boolean signIn(String name, String password) { MyThread myThread = new MyThread("http://本机IP:8080/cx/SignIn",name,password); try { myThread.start(); myThread.join(); } catch (InterruptedException e) { e.printStackTrace(); } return myThread.getResult(); } public static boolean signUp(String name, String password) { MyThread myThread = new MyThread("http://本机IP:8080/cx/SignUp",name,password); try { myThread.start(); myThread.join(); } catch (InterruptedException e) { e.printStackTrace(); } return myThread.getResult(); } } class MyThread extends Thread { private String path; private String name; private String password; private boolean result = false; public MyThread(String path,String name,String password) { this.path = path; this.name = name; this.password = password; } @Override public void run() { try { URL url = new URL(path); HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection(); httpURLConnection.setConnectTimeout(8000);//设置链接超时时间 httpURLConnection.setReadTimeout(8000);//设置读取超时时间 httpURLConnection.setRequestMethod("POST");//设置请求方法,post String data = "name=" + URLEncoder.encode(name, "utf-8") + "&password=" + URLEncoder.encode(password, "utf-8");//设置数据 httpURLConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");//设置响应类型 httpURLConnection.setRequestProperty("Content-Length", data.length() + "");//设置内容长度 httpURLConnection.setDoOutput(true);//容许输出 OutputStream outputStream = httpURLConnection.getOutputStream(); outputStream.write(data.getBytes("utf-8"));//写入数据 result = (httpURLConnection.getResponseCode() == 200); } catch (Exception e) { e.printStackTrace(); } } public boolean getResult() { return result; } }
MyThread myThread = new MyThread("http://本机IP:8080/cx/SignUp",name,password); MyThread myThread = new MyThread("http://本机IP:8080/cx/SignIn",name,password);
这两行换成本身的ip,本地ip的话能够用ipconfig或ifconfig查看,修改了默认端口的话也把端口一块儿改了.
路径的话就是
端口/web项目名/Servlet名
web项目名是再打成war包时设置的,Servlet名在web.xml中的<servlet>的子元素<servlet-name>设置,与java源码中的@WebServlet()注解中的一致
另一个要注意的就是线程问题,须要新开一个线程进行http的链接
前端页面部分很简单,就两个button,用于验证功能.
<?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:android="http://schemas.android.com/apk/res/android" android:layout_height="match_parent" android:layout_width="match_parent" android:orientation="vertical" > <LinearLayout android:layout_width="wrap_content" android:layout_height="wrap_content" android:orientation="horizontal"> <TextView android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="用户名" /> <EditText android:layout_width="300dp" android:layout_height="60dp" android:id="@+id/etname" /> </LinearLayout> <LinearLayout android:layout_width="wrap_content" android:layout_height="wrap_content" android:orientation="horizontal"> <TextView android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="密码" /> <EditText android:layout_width="300dp" android:layout_height="60dp" android:id="@+id/etpassword" /> </LinearLayout> <LinearLayout android:layout_width="wrap_content" android:layout_height="wrap_content" android:orientation="horizontal"> <Button android:layout_width="120dp" android:layout_height="60dp" android:text="注册" android:id="@+id/signup" /> <Button android:layout_width="120dp" android:layout_height="60dp" android:text="登陆" android:id="@+id/signin" /> </LinearLayout> </LinearLayout>
随便输入用户名与密码
查看数据库
这里没有加密保存,后期会添加加密保存
perfect!
这个错误在加载驱动错误时也可能会出现这个错误,所以要确保打成war包时lib目录正确且jar包版本正确.
还有就是因为这个是jdbc的底层实现,注意手写的sql语句不能错
千万千万别像我这样:
这个须要在AndroidManifest.xml添加网络权限
<uses-permission android:name="android.permission.INTERNET" /> <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" /> <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
服务器的话通常会有相应的相应的网页界面配置,好比做者的是阿里云服务器,固然也能够手动配置iptables
修改/etc/sysconfig/iptables
vim /etc/sysconfig/iptables
添加
-A INPUT -m state --state NEW -m tcp -p tcp --dport 8080 -j ACCEPT -A RH-Firewall-1-INPUT -m state --state NEW -m tcp -p tcp --dport 8080 -j ACCEPT
重启iptables
service iptables restart
因为从Android P开始,google默认要求使用加密链接,即要使用HTTPS,因此会禁止使用HTTP链接
使用HTTP链接时会出现如下异常
W/System.err: java.io.IOException: Cleartext HTTP traffic to **** not permitted java.net.UnknownServiceException: CLEARTEXT communication ** not permitted by network security policy
两种建议:
在res下新建一个文件夹xml,建立一个叫network_security_config.xml的文件,文件内容以下
<?xml version="1.0" encoding="utf-8"?> <network-security-config> <base-config cleartextTrafficPermitted="true" /> </network-security-config>
而后在AndroidMainfest.xml中加入
<application android:networkSecurityConfig="@xml/network_security_config" />
便可
另外一种办法是直接加入一句
android:usesCleartextTraffic="true"
<application android:usesCleartextTraffic="true" />
从android4.0开始,联网不能再主线程操做,万一网络很差就会卡死,因此有关联网的操做都须要新开一个线程,不能在主线程操做.
这个bug做者找了好久,http链接没问题,服务器没问题,数据库没问题,前端代码没问题,而后去了stackoverflow,发现是AVD的问题,我.......
简单来讲就是卸载了再重启AVD,竟然成功了.....
做者小白一枚,有什么不对的地方请你们指正,评论做者会好好回复的.
如下是个人CSDN博客
CSDN
参考网站
1.Android 经过Web服务器与Mysql数据库交互
2.Android高版本联网失败
3.IDEA 部署Web项目
4.PreparedStatement的executeQuery、executeUpdate和execute
5.preparedstatement execute()操做成功!可是返回false
6.HttpServletResponse(一)
7.HttpServletResponse(二)
8.HttpServletRequest
9.HttpUrlConnection
10.java.net.socketexception