十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
一、MongoDB数据库参数配置
晋江网站制作公司哪家好,找创新互联公司!从网页设计、网站建设、微信开发、APP开发、成都响应式网站建设公司等网站项目制作,到程序开发,运营维护。创新互联公司于2013年创立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联公司。
1、推荐使用mongodb.cfg.properties配置,则在构造MongoDBService对象的时候只需调用无参构造方法即可自动完成配置。
2、如果没有通过mongodb.cfg.properties,会采用程序指定的默认配置。
// 定义默认配置,1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名 private static final String MONGODB_ADDRESS = "127.0.0.1"; private static final int MONGODB_PORT = 27017; private static final String MONGODB_USERNAME = "root"; private static final String MONGODB_PASSWORD = ""; private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties"; private static final String MONGODB_DBNAME = "test"; private static final String MONGODB_COLLECTIONNAME = "test";
3、通过有参构造方法构造MongoDBService对象或通过get/set方法,指定数据库及集合,优先级最高。
//有参构造方法,指定数据库名与集合名 public MongoDBServiceImpl(String dbName, String collName) { this.dbName = dbName; this.collName = collName; try { db = getDb(); } catch (Throwable e) { e.printStackTrace(); } } //无参构造方法,返回配置文件配置的数据库对象引用,如果配置文件中没有设置则返回默认数据库对象引用 public MongoDBServiceImpl() { getDb(); } /* * 获取数据库对象,3种情况(优先级从高到低):span style="white-space: pre" /span *1、构造方法指定2、配置文件指定3、默认数据库span style="white-space: pre" /span *(情况2、3在MongoDButil中设置) */ public DB getDb() { if (this.db == null) { if (this.dbName == null) { this.db = MongoDBUtil.getDB(); } else { this.db = MongoDBUtil.getDBByName(this.dbName); } } return this.db; } /* * 获取集合对象,3种情况(优先级从高到低): *1、构造方法指定2、配置文件指定3、默认数据库 *(情况2、3在MongoDButil中设置) */ public DBCollection getCollection() { if(this.collName != null){ return db.getCollection(this.collName); } else { return MongoDBUtil.getDBCollection(); } }
二、方法简介(具体实现参看MongoDBServiceImpl接口实现类)
1、获取基本信息或对象:
(1)、获取数据库名: getDbName()
(2)、设置数据库名(指定数据库): setDbName(String dbName)
(3)、获取集合名: getCollName()
(4)、设置集合名(指定集合): setCollName(String collName)
(5)、获取数据库对象: getDb()
2、数据插入方式:
(1)、插入单条数据: insert(DBObject obj)
(2)、插入多条数据: insertBatch(List list)void
3、数据删除方式:
(1)、删除单条数据: delete(DBObject obj)
(2)、删除多条数据: deleteBatch(List list)
4、数量统计方式:
(1)、获取集合中数据数量: getCollectionCount()
(2)、获取符合条件的数据数量: getCount(DBObject obj)
5、查找数据:
(1)、查找所有数据: findAll()
(2)、查找符合条件的数据: find(DBObject obj)
(3)、查找符合条件的数据并排序: find(DBObject query, DBObject sort)
(4)、查找符合条件的指定数量的数据并排序:find(DBObject query, DBObject sort, int start, int limit)
(5)、由ID查找数据: getById(String id)
6、更新数据 :update(DBObject setFields, DBObject whereFields) void
7、打印List: printListDBObj(List list)
测试代码:(@Test)
public class testMongoService { //使用mongodb.cfg.properties中配置的数据库与集合,如未指定,使用MongoDBUtil中默认的数据库与集合 MongoDBService mongoDBService1 = new MongoDBServiceImpl(); //测试插入数据 @Test public void testInsert(){ //数据一,包括用户名、密码,地址信息(省份、城市),爱好[…] BasicDBList dbList1 = new BasicDBList(); dbList1.add("basketball"); dbList1.add("music"); dbList1.add("web"); DBObject dbObject1 = new BasicDBObject("username","insert1") .append("age", 18) .append("address", new BasicDBObject("province","广东").append("city", "广州")) .append("favourite", dbList1); //数据二 BasicDBList dbList2 = new BasicDBList(); dbList2.add("football"); dbList2.add("music"); DBObject dbObject2 = new BasicDBObject("username","insert2") .append("age", 18) .append("address", new BasicDBObject("province","陕西").append("city", "西安")) .append("favourite", dbList2); //数据三 BasicDBList dbList3 = new BasicDBList(); dbList3.add("Linux"); DBObject dbObject3 = new BasicDBObject("username","insert3") .append("age", 18) .append("address", new BasicDBObject("province","河北").append("city", "保定")) .append("favourite", dbList3); //数据四 BasicDBList dbList4 = new BasicDBList(); dbList4.add("swim"); dbList4.add("android"); DBObject dbObject4 = new BasicDBObject("username","insert4") .append("age", 18) .append("address", new BasicDBObject("province","四川").append("city", "成都")) .append("favourite", dbList4); //数据五 DBObject dbObject5 = new BasicDBObject("username", "insert5") .append("age", 28) .append("address", new BasicDBObject("city", "杭州")); mongoDBService1.printListDBObj(mongoDBService1.findAll()); System.out.println("——————————————————insert collection——————————————————"); Listdbobject list = new ArrayListdbobject(); list.add(dbObject1); list.add(dbObject2); list.add(dbObject3); list.add(dbObject5); mongoDBService1.insertBatch(list); System.out.println("——————————————————insert one——————————————————"); mongoDBService1.insert(dbObject4); mongoDBService1.printListDBObj(mongoDBService1.findAll()); } //测试查询数据 @Test public void testFind(){ DBObject dbObject = new BasicDBObject("username","insert1"); System.out.println("数量:" + mongoDBService1.getCollectionCount()); System.out.println("username=java的数据数量:" + mongoDBService1.getCount(dbObject)); System.out.println("——————————————————find all——————————————————"); mongoDBService1.printListDBObj(mongoDBService1.findAll()); System.out.println("——————————————————find obj——————————————————"); mongoDBService1.printListDBObj(mongoDBService1.find(dbObject)); System.out.println("——————————————————find sort——————————————————"); mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1))); System.out.println("——————————————————find sort limit——————————————————"); mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1), 1, 2)); } //测试数据更新 @Test public void testUpdate(){ BasicDBObject newDocument = new BasicDBObject("$set",new BasicDBObject("age",11)); BasicDBObject searchQuery = new BasicDBObject().append("username", "insert2"); mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery)); System.out.println("——————————————————update——————————————————"); mongoDBService1.update(newDocument, searchQuery); mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery)); } //测试数据删除 @Test public void testDelete(){ DBObject dbObject1 = new BasicDBObject("username", "insert1"); DBObject dbObject2 = new BasicDBObject("username", "insert2"); DBObject dbObject3 = new BasicDBObject("username", "insert3"); DBObject dbObject4 = new BasicDBObject("username", "insert4"); DBObject dbObject5 = new BasicDBObject("username", "insert5"); Listdbobject list = new ArrayListdbobject(); list.add(dbObject1); list.add(dbObject2); list.add(dbObject3); list.add(dbObject4); mongoDBService1.printListDBObj(mongoDBService1.findAll()); System.out.println("——————————————————delete list——————————————————"); mongoDBService1.deleteBatch(list); System.out.println("——————————————————delete one——————————————————"); mongoDBService1.delete(dbObject5); //System.out.println("——————————————————delete all——————————————————"); //mongoDBService1.delete(new BasicDBObject()); mongoDBService1.printListDBObj(mongoDBService1.findAll()); }}/dbobject/dbobject/dbobject/dbobject
测试结果:
源代码:(完整项目文件下载链接:点击打开链接)
MongoDBServiceImpl.java
public class MongoDBServiceImpl implements MongoDBService { private String dbName; private String collName; private DB db; //有参构造方法,指定数据库名与集合名 public MongoDBServiceImpl(String dbName, String collName) { this.dbName = dbName; this.collName = collName; try { db = getDb(); } catch (Throwable e) { e.printStackTrace(); } } //无参构造方法,返回配置文件配置的数据库对象引用,如果配置文件中没有设置则返回默认数据库对象引用 public MongoDBServiceImpl() { getDb(); } /* * 获取数据库对象,3种情况(优先级从高到低): *1、构造方法指定2、配置文件指定3、默认数据库 *(情况2、3在MongoDButil中设置) */ public DB getDb() { if (this.db == null) { if (this.dbName == null) { this.db = MongoDBUtil.getDB(); } else { this.db = MongoDBUtil.getDBByName(this.dbName); } } return this.db; } /* * 获取集合对象,3种情况(优先级从高到低): *1、构造方法指定2、配置文件指定3、默认数据库 *(情况2、3在MongoDButil中设置) */ public DBCollection getCollection() { if(this.collName != null){ return db.getCollection(this.collName); } else { return MongoDBUtil.getDBCollection(); } } public DBObject map2Obj(Mapstring, object="" map) { DBObject obj = new BasicDBObject(); if (map.containsKey("class") map.get("class") instanceof Class) map.remove("class"); obj.putAll(map); return obj; } //插入数据 public void insert(DBObject obj) { getCollection().insert(obj); } //插入多条数据 public void insertBatch(Listdbobject list) { if (list == null || list.isEmpty()) { return; } Listdbobject listDB = new ArrayListdbobject(); for (int i = 0; i list.size(); i++) { listDB.add(list.get(i)); } getCollection().insert(listDB); } //删除数据 public void delete(DBObject obj) { getCollection().remove(obj); } //删除多条数据 public void deleteBatch(Listdbobject list) { if (list == null || list.isEmpty()) { return; } for (int i = 0; i list.size(); i++) { getCollection().remove(list.get(i)); } } //获取集合中的数据数量 public long getCollectionCount() { return getCollection().getCount(); } //查找符合条件的数据数量 public long getCount(DBObject obj) { if (obj != null) return getCollection().getCount(obj); return getCollectionCount(); } //查找符合条件的数据 public Listdbobject find(DBObject obj) { DBCursor cur = getCollection().find(obj); return DBCursor2list(cur); } //查找符合条件的数据并排序 @Override public Listdbobject find(DBObject query, DBObject sort) { DBCursor cur; if (query != null) { cur = getCollection().find(query); } else { cur = getCollection().find(); } if (sort != null) { cur.sort(sort); } return DBCursor2list(cur); } //查找符合条件的数据并排序,规定数据个数 @Override public Listdbobject find(DBObject query, DBObject sort, int start, int limit) { DBCursor cur; if (query != null) { cur = getCollection().find(query); } else { cur = getCollection().find(); } if (sort != null) { cur.sort(sort); } if (start == 0) { cur.batchSize(limit); } else { cur.skip(start).limit(limit); } return DBCursor2list(cur); } //将DBCursor转化为listdbobject private Listdbobject DBCursor2list(DBCursor cur) { Listdbobject list = new ArrayListdbobject(); if (cur != null) { list = cur.toArray(); } return list; } //更新数据 public void update(DBObject setFields, DBObject whereFields) { getCollection().updateMulti(whereFields, setFields); } //查询集合中所有数据 public Listdbobject findAll() { DBCursor cur = getCollection().find(); Listdbobject list = new ArrayListdbobject(); if (cur != null) { list = cur.toArray(); } return list; } //由ID获取数据 public DBObject getById(String id) { DBObject obj = new BasicDBObject(); obj.put("_id", new ObjectId(id)); DBObject result = getCollection().findOne(obj); return result; } public String getDbName() { return dbName; } public void setDbName(String dbName) { this.dbName = dbName; this.db = MongoDBUtil.getDBByName(this.dbName); } public String getCollName() { return collName; } public void setCollName(String collName) { this.collName = collName; } @Override public void printListDBObj(Listdbobject list) { // TODO Auto-generated method stub for(DBObject dbObject: list){ System.out.println(dbObject); } } }/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/dbobject/string,
MongoDBUtil.java
public class MongoDBUtil { // 定义默认配置,1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名 private static final String MONGODB_ADDRESS = "127.0.0.1"; private static final int MONGODB_PORT = 27017; private static final String MONGODB_USERNAME = "root"; private static final String MONGODB_PASSWORD = ""; private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties"; private static final String MONGODB_DBNAME = "test"; private static final String MONGODB_COLLECTIONNAME = "test"; // 定义静态变量,1、Mongo对象(代表数据库连接)2、DB对象(代表数据库)3、集合名4、数据库相关配置映射集合5、已获取的数据库连接 private static Mongo mongo; private static DB db; private static DBCollection collection; private static Mapstring, string="" cfgMap = new HashMapstring, string=""(); private static Hashtablestring, db="" mongoDBs = new Hashtablestring, db=""(); /** * 初始化Mongo的数据库 */ static { init(); } /** * 获取配置文件中配置的DB对象 */ public static DB getDB() { return db; } /** * 获取配置文件中配置的DBCollection对象 */ public static DBCollection getDBCollection() { return collection; } /** * 根据数据库名称,得到数据库 如果不存在,则创建一个该名称的数据库,并设置用户名和密码为配置文件中的参数值 * * @param dbName * @return DB */ @SuppressWarnings("deprecation") public static DB getDBByName(String dbName) { DB db = mongo.getDB(dbName); if (!mongoDBs.contains(db)) { System.out.println("add"); db.addUser(cfgMap.get("mongo.db.username"), cfgMap.get("mongo.db.password").toCharArray()); mongoDBs.put(dbName, db); } return db; } // ————————————————————————————————————初始化过程———————————————————————————————————— /** * 获取配置文件mongedb.cfg.properties的文件对象 */ public static File getConfigFile() { String path = MongoDBUtil.class.getResource("/").getPath(); String fileName = path + MONGODB_RESOURCE_FILE; System.out.println(fileName); File file = new File(fileName); if (file.exists()) { return file; } return null; } /** * 通过mongedb.cfg.properties配置文件初始化配置映射集合,如果没有编写配置文件,则加载程序指定的默认配置 */ @SuppressWarnings("unchecked") private static void initCfgMap() { File file = getConfigFile(); if (file != null) { Properties p = new Properties(); try { p.load(new FileInputStream(file)); for (Enumeration enu = p.propertyNames(); enu.hasMoreElements();) { String key = (String) enu.nextElement(); String value = (String) p.getProperty(key); cfgMap.put(key, value); } } catch (IOException e) { System.out.println("加载Mongo配置文件失败!"); e.printStackTrace(); } } else { // 如果没有编写配置文件,则加载默认配置 cfgMap.put("mongo.db.address", MONGODB_ADDRESS); cfgMap.put("mongo.db.port", String.valueOf(MONGODB_PORT)); cfgMap.put("mongo.db.username", MONGODB_USERNAME); cfgMap.put("mongo.db.password", MONGODB_PASSWORD); cfgMap.put("mongo.db.dbname", MONGODB_DBNAME); cfgMap.put("mongo.db.collectionname", MONGODB_COLLECTIONNAME); } } /** * 初始化Mongo的数据库(将db指向相应对象引用,将collection指向相应对象引用,通过mongoDBs记录现有数据库对象) */ @SuppressWarnings("deprecation") private static void init() { initCfgMap(); try { String address = cfgMap.get("mongo.db.address"); int port = Integer.parseInt(cfgMap.get("mongo.db.port").toString()); String dbName = cfgMap.get("mongo.db.dbname"); String username = cfgMap.get("mongo.db.username"); String password = cfgMap.get("mongo.db.password"); String collectionName = cfgMap.get("mongo.db.collectionname"); mongo = new Mongo(address, port); if (dbName != null !"".equals(dbName)) { db = mongo.getDB(dbName); if (username != null !"".equals(username)) { db.addUser(username, password.toCharArray()); if (collectionName != null !"".equals(collectionName)) { collection = db.getCollection(collectionName); } } mongoDBs.put(dbName, db); } } catch (Exception e) { e.printStackTrace(); } } }
首先你得确定你的数据库连接是通过什么形式连接的,hibernate还是原生态的jdbc 还是spring;
如果是只有hibernate,那么你得通过加载配置文件得到sessionFactory,然后得到session
如果spring,那么同样也需要注入sessionfactory到你的dao
如果是jdbc方式,那么你就按照原生态jdbc写法
总之,在你构造DAO时,得有数据源。这样才能操纵你的数据库
如果搞懂了这些问题,那么你的第一个,第三个问题就迎刃而解了。至于第二问题,我没明白你什么意思!
看一下--------SubjectAction
public String deleteSubject(){
isubjectbiz.deleteSubject(subjectId);
return SUCCESS;
}
subjectId 是否是用struts2 自动从页面封装过来的 还是你使用request获取的 首先你输出一下有没有值 然后如果是request获取的 必须要把它转换成integer 其次如果有值 且为integer 这时你就要检查你的数据库隐射文件是否正确 一级一级排除
package org.dao;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.Date;
import org.dbc.DBManageer;
import org.dbc.DBUtil;
import org.vo.CardInfo;
public class CardInfoDao {
public void testResultSetMetaData() {
String sql = "select * from cardinfo";
Connection con = new DBUtil().getConnection();
PreparedStatement ps = null;
ResultSetMetaData rsmd = null;
ResultSet rs = null;
try {
ps = con.prepareStatement(sql);
rs = ps.executeQuery();
rsmd = rs.getMetaData();
for (int i = 1; i rsmd.getColumnCount(); i++) {
System.out.print(" 数据类型名:" + rsmd.getColumnClassName(i));
System.out.print(" 别名:" + rsmd.getColumnLabel(i));
System.out.print(" 列名:" + rsmd.getColumnName(i));
System.out.print(" 数据类型:" + rsmd.getColumnTypeName(i));
System.out.println(" 数据类型:" + rsmd.getColumnType(i));
}
while (rs.next()) {
// 通过反射可以对VO对象(CardInfo)自动赋值
// for(...)
// CardInfo ci=new CardInfo();
// ci.setId(rs.getInt(columnIndex))
/*
* CardInfo ca = new CardInfo(); Class cc = ca.getClass();
*/
/*Class? c = Class.forName("org.vo.CardInfo");
CardInfo ca = (CardInfo) c.newInstance();
ca.setCardId(rs.getString("cardId"));
ca.setCustomerName(rs.getString("customerName"));
ca.setCurrentMoney(rs.getFloat("currentMoney"));
ca.setOpenDate(rs.getDate("openDate"));
System.out.println(ca);//ok */
//加载一个CardInfo类
Class c = Class.forName("org.vo.CardInfo");
Object o = c.newInstance(); //获得它的一个实例
//定义String类的对象数组
Class[] params = new Class[] { String.class};
//定义float类的对象数组
Class[] floatparams = new Class[] { float.class};
//定义Date(util)类的对象数组
Class[] dateparams = new Class[] { Date.class};
//获得setCardId方法
Method me = c.getMethod("setCardId", params);
//实例方法的参数
Object []ostr = new Object[]{rs.getString("cardId")};
//如果底层方法是静态的,那么可以忽略指定的 obj 参数。该参数可以为 null。
//如果底层方法所需的形参数为 0,则所提供的 args 数组长度可以为 0 或 null。
//o 调用方法的对象 ostr 方法调用的参数
me.invoke(o, ostr);
//获得setCustomerName方法
Method name = c.getMethod("setCustomerName", params);
Object []cusname = new Object[]{rs.getString("customerName")};
name.invoke(o,cusname);
//获得setCurrentMoney方法
Method money = c.getMethod("setCurrentMoney", floatparams);
Object []cusmoney = new Object[]{rs.getFloat("currentMoney")};
money.invoke(o,cusmoney);
//获得setOpenDate方法
Method date = c.getMethod("setOpenDate",dateparams);
Object []openDate = new Object[]{rs.getDate("openDate")};
date.invoke(o, openDate);
//打印
System.out.println(o);
}
} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (SecurityException e) {
e.printStackTrace();
}catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (NoSuchMethodException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}
public void showResultSet() {
String sql = "select * from cardinfo";
Connection con = new DBManageer().getConnection();
PreparedStatement ps = null;
try {
ps = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
ResultSet rs = ps.executeQuery();
System.out.println("---依次读取------");
while (rs.next()) {
CardInfo ca = new CardInfo();
ca.setCardId(rs.getString("cardId"));
ca.setCustomerName(rs.getString("customerName"));
ca.setCurrentMoney(rs.getFloat("currentMoney"));
ca.setOpenDate(rs.getDate("openDate"));
System.out.println(ca);
}
System.out.println("---倒读------");
while (rs.previous()) {
CardInfo ca = new CardInfo();
ca.setCardId(rs.getString("cardId"));
ca.setCustomerName(rs.getString("customerName"));
ca.setCurrentMoney(rs.getFloat("currentMoney"));
ca.setOpenDate(rs.getDate("openDate"));
System.out.println(ca);
}
rs.absolute(3);// 定位倒第几行
rs.updateString("customerName", "star");
// rs.updateRow();
rs.beforeFirst();
while (rs.next()) {
CardInfo ca = new CardInfo();
ca.setCardId(rs.getString("cardId"));
ca.setCustomerName(rs.getString("customerName"));
ca.setCurrentMoney(rs.getFloat("currentMoney"));
ca.setOpenDate(rs.getDate("openDate"));
System.out.println(ca);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
连接数据库
public class DBManager {
//定义数据库连接的URL
private static final String URL="jdbc:sqlserver://localhost:1433;database=j1105";
//定义数据库的用户名
private static final String USERNAME = "sa";
//定义数据库密码
private static final String PASSWORD = "sa";
//定义一个连接的引用,使用单例模式
private static Connection conn = null;
//使用静态块来注册驱动
//类加载时自动执行代码块
static {
//反射com.microsoft.sqlserver.jdbc.SQLServerDriver.class
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
//获得连接
//在程序使用过程中始终只有1个对象存在
//使用单例模式来给Connection赋值
public static Connection getConnection(){
if(conn == null){
try {
conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
}
return conn;
}
/**
* 关闭的一些操作 , 优化
* @param conn
* @param stat
* @param rs
*/
public static void close(Connection conn,Statement stat,ResultSet rs){
try{
if(conn != null){
conn.close();
}
if(stat != null){
stat.close();
}
if(rs != null){
rs.close();
}
}catch(SQLException e){
e.printStackTrace();
}
}
/**
* 重写上面的方法,在只有2个参数的情况下关闭
* @param conn
* @param stat
*/
public static void close(Connection conn,Statement stat){
try{
if(conn != null){
conn.close();
}
if(stat != null){
stat.close();
}
}catch(SQLException e){
e.printStackTrace();
}
}
public static void main(String[] args){
Connection conn = DBManager .getConnection();
System.out.println(conn);
}
}
接口
public interface IStudentDao {
public void deleteStudent(int xh);
}
实现
public class StudentDAOimpl implements IStudentDao {
public void deleteStudent(int xh) {
try{
String sql = "delete from tb_student where xh = ?";
PreparedStatement ps = conn.prepareStatement(sql);
ps.setInt(1, xh);
ps.executeUpdate();
System.out.println("成功删除");
}catch(SQLException e){
e.printStackTrace();
}
}
}