Android连接数据库，局域网连接失败问题
2022-05-17 本文已影响0人
JackSpeed
在Android 应用中直接连接数据库，遇到Could not create connection to database server. Attempted reconnect 3 times. Giving up.问题。
首先总结几个可能出现问题的地方：
- 数据库登录账号未开启远程登录权限
- 数据库驱动（jar包）不匹配
- 账号密码不匹配
- 在主线程连接数据库---（参考文末源码）
其中最难排查的是第二点——数据库驱动问题
数据库登录账号未开启远程登录权限解决
默认情况下MySQL用户没有远程登录的权限，需要修改mysql的user表配置
无远程登录权限
执行SQL操作，改成指定IP或者所有IP，对于Android测试来说我这里改成所有IP。
create user 'test'@'%' identified by '123456.*';
grant all privileges on *.* to 'test'@'%' with grant option;
flush privileges;
修改后的
test任意IP登录
在驱动没问题时，应该可以正常连接数据库了。
数据库驱动（jar包）不匹配问题解决
一开始使用阿里云公网服务器部署的MySQL，使用5.1.29，能连接阿里云的远程数据库；当数据库换成局域网内的数据库时，就出现Could not create connection to database server. Attempted reconnect 3 times. Giving up.问题。经过网上查看大佬的资料，有的说是驱动版本不合适，于是乎换了好几个版本，最终5.1.49的可行。
版本匹配建议：
mysql版本8.0.26 -------> Android端jar包版本 mysql-connector-java-5.1.49.jar
mysql版本5.6.50 -------> Android端jar包版本 mysql-connector-java-5.1.49.jar
mysql版本5.7.37 -------> Android端jar包版本 mysql-connector-java-5.1.46.jar
查询链接成功，但是查不到数据时，可尝试配置
useSSL=false&characterEncoding=UTF-8&autoReconnect=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai
数据库驱动下载地址
https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.49.zip
源码
import android.os.StrictMode;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class DbHelper {
/**
* MySQL 驱动
*/
private static final String driver = "com.mysql.jdbc.Driver";
/**
* MYSQL数据库连接Url
*/
private static final String url = "jdbc:mysql://192.168.0.105:3306/test?useSSL=false&characterEncoding=UTF-8&autoReconnect=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai";
private static final String user = "test";
private static final String password = "123456.*";
/**
* 连接数据库
*/
public static Connection getConn() throws ClassNotFoundException, SQLException {
StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().permitAll().build();
StrictMode.setThreadPolicy(policy);
//获取MYSQL驱动,
Class<?> aClass = Class.forName(driver);
//获取连接
return DriverManager.getConnection(url, user, password);
}
/**
* 关闭数据库
*/
public static void closeAll(Connection conn, PreparedStatement ps) {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 关闭数据库
*/
public static void closeAll(Connection conn, PreparedStatement ps, ResultSet rs) {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (ps != null) {
try {
ps.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
import com.ycj.weight.models.DataModel;
import com.ycj.weight.models.GoodsModel;
import com.ycj.weight.ui.base.BaseActivity;
import com.ycj.weight.utils.ActivityStack;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
public class DBUtil {
private static class Inner {
private static final DBUtil DB_SERVICE = new DBUtil();
}
public static DBUtil getInstance() {
return DBUtil.Inner.DB_SERVICE;
}
/**
* 打开数据库对象
*/
private Connection conn = null;
/**
* 操作整合sql语句的对象
*/
private PreparedStatement ps = null;
/**
* 查询结果的集合
*/
private ResultSet rs = null;
/**
* 构造方法 私有化
*/
private DBUtil() {
}
/**
* 存储数据
*/
public boolean putWeightInfo(DataModel dataModel) {
String sql = "insert into data_b(ID,ORDER_TYPE)" +
" values ('" + dataModel.getID() + "','" + dataModel.getORDER_TYPE() + "')";
//获取链接数据库对象
try {
conn = DbHelper.getConn();
if (conn != null && (!conn.isClosed())) {
ps = conn.prepareStatement(sql);
if (ps != null) {
ps.execute();
return true;
}
}
} catch (Exception e) {
e.printStackTrace();
showToast(e);
}
//关闭相关操作
DbHelper.closeAll(conn, ps, rs);
return false;
}
public DataModel queryResult(String dataModelID) {
//结果存放集合
//MySQL 语句
String sql = "select * from data_b where ID = '" + dataModelID + "' limit 1";
DataModel jsonObj = null;
//获取链接数据库对象
try {
conn = DbHelper.getConn();
if (conn != null && (!conn.isClosed())) {
ps = conn.prepareStatement(sql);
if (ps != null) {
rs = ps.executeQuery();
if (rs != null) {
while (rs.next()) {
jsonObj = new DataModel();
jsonObj.setID(rs.getString("ID"));
jsonObj.setORDER_TYPE(rs.getString("ORDER_TYPE"));
}
}
}
}
} catch (Exception e) {
e.printStackTrace();
showToast(e);
}
//关闭相关操作
DbHelper.closeAll(conn, ps, rs);
return jsonObj;
}
/**
* 查询商品列表
*
* @return GoodsModel
*/
public List<GoodsModel> queryGoodsList() {
//结果存放集合
List<GoodsModel> list = new ArrayList<>();
//MySQL 语句
String sql = "select * from t_goods where status = 1";
//获取链接数据库对象
try {
conn = DbHelper.getConn();
if (conn != null && (!conn.isClosed())) {
ps = conn.prepareStatement(sql);
if (ps != null) {
rs = ps.executeQuery();
if (rs != null) {
while (rs.next()) {
GoodsModel u = new GoodsModel();
u.setID(rs.getString("ID"));
u.setNAME(rs.getString("NAME"));
list.add(u);
}
}
}
}
} catch (Exception e) {
e.printStackTrace();
showToast(e);
}
//关闭相关操作
DbHelper.closeAll(conn, ps, rs);
return list;
}
private static void showToast(Exception e) {
//toast开发调试用
BaseActivity lastActivity = ActivityStack.getLastActivity();
if (lastActivity != null) {
lastActivity.runOnUiThread(() -> lastActivity.showLongToast("getConn异常" + e.getMessage()));
}
}
}
