System.out.println(\执行executeQuery(String sql)方法出错:\我们要养成习惯如果发生了错误首先看打印出来的sql语句有没有问题 e.printStackTrace();//打印出错误原因 } } /**
* 数据库增加/删除/修改
* @param sql 传入的SQL语句 * @return >0执行成功 */
public int executeUpdate(String sql){ int ret=-1; try{ ret=st.executeUpdate(sql);//执行SQL语句对数据表进行操作,变量ret存放对表修改了多少行 }catch(Exception e){ System.out.println(\执行executeUpdate(sql)方法出错:\ e.printStackTrace();//打印出错误原因 }finally{ close(); } return ret; } /**
* 数据库关闭 */
public void close(){ try { if (rs!=null){ rs.close();//关闭结果集 } if (st!=null){ st.close();//关闭Statement对象 } if (conn!=null){ conn.close();//关闭连接 }
}catch(Exception e){ System.out.println(\执行close()方法出错:\ e.printStackTrace(); } } }
package com.zdsoft.po; public class City {
private String cityId; private String cityName; private String cityCountry; private String cityNote;
public String getCityId() { return cityId; }
public void setCityId(String cityId) { this.cityId = cityId; }
public String getCityName() { return cityName; }
public void setCityName(String cityName) { this.cityName = cityName; }
public String getCityCountry() { return cityCountry; }
public void setCityCountry(String cityCountry) { this.cityCountry = cityCountry; }
public String getCityNote() { return cityNote; }
public void setCityNote(String cityNote) { this.cityNote = cityNote; } }
package com.zdsoft.dao; import java.sql.ResultSet;
import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.DBUtil;
import com.zdsoft.po.City; public class CityDao { DBUtil db = null;
public CityDao() { db = new DBUtil(); }
public City findcity(String city_name) { String sql = \ + city_name + \ db.executeQuery(sql); ResultSet res = db.getRs(); City c = new City(); try { while (res.next()) { c.setCityId(res.getString(\ c.setCityCountry(res.getString(\ c.setCityName(res.getString(\ c.setCityNote(res.getString(\ } } catch (SQLException e) {
e.printStackTrace();
} return c; }
public void deleteCity(String city_id) { String sql = \ if (db.executeUpdate(sql) > 0) { System.out.println(\数据删除成功\ } else { System.out.println(\数据删除失败\ } } }
package com.zdsoft.access; import java.util.List;
import com.zdsoft.dao.CityDao; import com.zdsoft.po.City; public class Access { public static void main(String[] args) { CityDao dao = new CityDao(); City s = dao.findcity(\重庆\ System.out.print(s.getCityId());
}
}
System.out.print(s.getCityName()); System.out.print(s.getCityCountry()); System.out.println(s.getCityNote()); dao.deleteCity(\
(二)、用数据库存放用户信息(难)
1.创建名为test的数据库
2.在数据库test中创建用户 (User)表 字段 User _id User _name User _pass User _date 描述 用户编号 用户帐号 用户密码 创建时间 长度 32 30 30 类型 Varchar Varchar Varchar Date 备注 Pk(主键)
3.建立一个类来封装用户信息(User),放在com.zdsoft.po包下 提供四个私有属性: 用户编号 用户帐号 用户密码 创建时间
4.建立UserDao类,利用DBUtil类 建立方法对用户信息进行查询与删除操作 该类放在com.zdsoft.dao包下
1) 建立方法通过用户编号查询某个用户信息
public User findUser(String User_id)
注:查询出来的用户信息封装在User 对象里
2) 能够通过Id删除某条用户信息
public void deleteUser(String User_id)
5.建立Access类在main函数中测试对用户表的查,删方法 该类放在com.zdsoft.access包下. package com;
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.Statement; public class DBUtil { private Connection conn = null; // 数据库连接对象 private Statement st = null;// 执行sql语句的对象 private ResultSet rs = null;// 存放查询结果的对象 /** * 获得ResultSet * @return ResultSet
*/ public ResultSet getRs() { return rs; } /** * 获得数据库连接 */ private void getConnection() { final String DRIVERNAME = \ final String URL = \ final String LOGIN = \数据库管理员用户名 final String PASSWORD = \数据库密码 try { Class.forName(DRIVERNAME); // 加载驱动程序 conn = DriverManager.getConnection(URL, LOGIN, PASSWORD); } catch (Exception e) { System.out.println(\执行getConnection()方法出错:\ e.printStackTrace(); } } public DBUtil(){ getConnection(); try { st = conn.createStatement(); } catch (SQLException e) { e.printStackTrace(); } } /** * 数据库查询 * @param sql 传入的SQL语句 */
public void executeQuery(String sql){ try{ rs=st.executeQuery(sql);//执行SQL语句获得结果集 }catch(Exception e){ System.out.println(\执行executeQuery(String sql)方法出错:\ e.printStackTrace();//打印出错误原因 } } /**