Android(安卓)连接MySQL数据库并进行增删改查操作
16lz
2022-07-27
1.Android 连接MySQL数据库
public class DBOpenHelper { private static String driver = "com.mysql.jdbc.Driver";//MySQL 驱动 private static String url = "jdbc:mysql://IP:3306/数据库";//MYSQL数据库连接Url private static String user = "root";//用户名 private static String password = "root";//密码 /** * 连接数据库 * */ public static Connection getConn(){ Connection conn = null; try { Class.forName(driver);//获取MYSQL驱动 conn = (Connection) DriverManager.getConnection(url, user, password);//获取连接 } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; } /** * 关闭数据库 * */ 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(); } } }}2.增删改查
public class DBService { private Connection conn=null; //打开数据库对象 private PreparedStatement ps=null;//操作整合sql语句的对象 private ResultSet rs=null;//查询结果的集合 //DBService 对象 public static DBService dbService=null; /** * 构造方法 私有化 * */ private DBService(){ } /** * 获取MySQL数据库单例类对象 * */ public static DBService getDbService(){ if(dbService==null){ dbService=new DBService(); } return dbService; } /** * 获取要发送短信的患者信息 查 * */ public List getUserData(){ //结果存放集合 List list=new ArrayList(); //MySQL 语句 String sql="select * from user"; //获取链接数据库对象 conn= DBOpenHelper.getConn(); try { if(conn!=null&&(!conn.isClosed())){ ps= (PreparedStatement) conn.prepareStatement(sql); if(ps!=null){ rs= ps.executeQuery(); if(rs!=null){ while(rs.next()){ User u=new User(); u.setId(rs.getString("id")); u.setName(rs.getString("name")); u.setPhone(rs.getString("phone")); u.setContent(rs.getString("content")); u.setState(rs.getString("state")); list.add(u); } } } } } catch (SQLException e) { e.printStackTrace(); } DBOpenHelper.closeAll(conn,ps,rs);//关闭相关操作 return list; } /** * 修改数据库中某个对象的状态 改 * */ public int updateUserData(String phone){ int result=-1; if(!StringUtils.isEmpty(phone)){ //获取链接数据库对象 conn= DBOpenHelper.getConn(); //MySQL 语句 String sql="update user set state=? where phone=?"; try { boolean closed=conn.isClosed(); if(conn!=null&&(!closed)){ ps= (PreparedStatement) conn.prepareStatement(sql); ps.setString(1,"1");//第一个参数state 一定要和上面SQL语句字段顺序一致 ps.setString(2,phone);//第二个参数 phone 一定要和上面SQL语句字段顺序一致 result=ps.executeUpdate();//返回1 执行成功 } } catch (SQLException e) { e.printStackTrace(); } } DBOpenHelper.closeAll(conn,ps);//关闭相关操作 return result; } /** * 批量向数据库插入数据 增 * */ public int insertUserData(List list){ int result=-1; if((list!=null)&&(list.size()>0)){ //获取链接数据库对象 conn= DBOpenHelper.getConn(); //MySQL 语句 String sql="INSERT INTO user (name,phone,content,state) VALUES (?,?,?,?)"; try { boolean closed=conn.isClosed(); if((conn!=null)&&(!closed)){ for(User user:list){ ps= (PreparedStatement) conn.prepareStatement(sql); String name=user.getName(); String phone=user.getPhone(); String content=user.getContent(); String state=user.getState(); ps.setString(1,name);//第一个参数 name 规则同上 ps.setString(2,phone);//第二个参数 phone 规则同上 ps.setString(3,content);//第三个参数 content 规则同上 ps.setString(4,state);//第四个参数 state 规则同上 result=ps.executeUpdate();//返回1 执行成功 } } } catch (SQLException e) { e.printStackTrace(); } } DBOpenHelper.closeAll(conn,ps);//关闭相关操作 return result; } /** * 删除数据 删 * */ public int delUserData(String phone){ int result=-1; if((!StringUtils.isEmpty(phone))&&(PhoneNumberUtils.isMobileNumber(phone))){ //获取链接数据库对象 conn= DBOpenHelper.getConn(); //MySQL 语句 String sql="delete from user where phone=?"; try { boolean closed=conn.isClosed(); if((conn!=null)&&(!closed)){ ps= (PreparedStatement) conn.prepareStatement(sql); ps.setString(1, phone); result=ps.executeUpdate();//返回1 执行成功 } } catch (SQLException e) { e.printStackTrace(); } } DBOpenHelper.closeAll(conn,ps);//关闭相关操作 return result; }} 更多相关文章
- 类和 Json对象
- Android系统配置数据库注释(settings.db)
- Android中文API（144） —— JsonWriter
- Android之Handler用法总结
- android通过ksoap2对webservice的解析
- Android(安卓)View的介绍和使用
- Android中，把XML文件转换成Object对象的方法
- Android(安卓)-- Android(安卓)JUint 与 Sqlite
- android 当系统存在多个Launcher时，如何设置开机自动进入默认的La