重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
首先你得确定你的数据库连接是通过什么形式连接的,hibernate还是原生态的jdbc 还是spring;
成都创新互联公司-专业网站定制、快速模板网站建设、高性价比确山网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式确山网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖确山地区。费用合理售后完善,十年实体公司更值得信赖。
如果是只有hibernate,那么你得通过加载配置文件得到sessionFactory,然后得到session
如果spring,那么同样也需要注入sessionfactory到你的dao
如果是jdbc方式,那么你就按照原生态jdbc写法
总之,在你构造DAO时,得有数据源。这样才能操纵你的数据库
如果搞懂了这些问题,那么你的第一个,第三个问题就迎刃而解了。至于第二问题,我没明白你什么意思!
1、首先在电脑上启动数据库 ,在数据库中创建表,下面给出具体的SQL语句。
2、然后打开eclipse 创建新项目 JDBCTest,需要导入相关的jar包并构建路径,如图。
3、接着创建entity实体层如图对应表中的数据。
4、创建数据连接层conn 用于MySQL数据库的连接代码如图 如图。
5、创建dao层持久层,在里面编写数据库表的增删改查的具体操作。
6、最后编写测试类 Test代码如图,就完成了。
Struts是针对action的(model层),它本身不具有增删改查功能的。
扩展:要通过dao层(spring事务管理)来做增删改查功能的。
可以参考下如下代码实现增删改查:
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import Bean.Bean;
public class shixian implements DAO {
public void delete(Bean bean) throws Exception {
// 删除数据
String sql = "delete from person where name=?";
Conn conn = new Conn();//创建数据库连接
PreparedStatement pre;
try {
//获取连接,执行sql
pre = conn.getConn().prepareStatement(sql);
pre.setString(1, bean.getName());
pre.executeUpdate();
pre.close();//关闭数据库连接
} catch (Exception e) {
e.printStackTrace();
}
}
public void insert(Bean bean) throws Exception {
// 增加数据
String sql = "insert into person values(?,?)";
Conn conn = new Conn();//创建数据库连接
PreparedStatement pre = null;
try {
//获取连接,执行sql
pre = conn.getConn().prepareStatement(sql);
pre.setString(1, bean.getName());
pre.setString(2, bean.getPassword());
pre.executeUpdate();
pre.close();//关闭数据库连接
}
catch (Exception e) {
e.printStackTrace();
}
}
public Bean select(String name) throws Exception {
// 查询数据
String sql = "select name,password from person where name=?";
Conn conn=new Conn();//创建数据库连接
Bean bean = new Bean();
PreparedStatement pre = null;
try{
//获取连接,执行sql
pre = conn.getConn().prepareStatement(sql);
pre.setString(1, name);
ResultSet rs = pre.executeQuery();
if (rs.next()) {
bean.setName(rs.getString(1));
bean.setPassword(rs.getString(2));
}
rs.close();
pre.close();//关闭数据库连接
} catch (Exception e) {
e.printStackTrace();
}
return bean;
}
public void update(Bean bean) throws Exception {
// 修改数据
String sql = "insert into person values(?,?)";
Conn conn = new Conn();//创建数据库连接
PreparedStatement pre = null;
try {
//获取连接,执行sql
pre = conn.getConn().prepareStatement(sql);
pre.setString(1, bean.getName());
pre.setString(1, bean.getPassword());
pre.executeUpdate();
pre.close();//关闭数据库连接
}
catch (Exception e) {
e.printStackTrace();
}
}
}