package custom.dao;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import custom.struts.form.SellerForm;
import custom.struts.form.CustomForm;
import custom.dao.ConnectionManager;
public class SellerDao {
/*针对seller表*/
//1,查询
public static List findAll(Connection conn){
Statement stmt = null;
ResultSet rs = null;
List list = new ArrayList();
try{
conn = ConnectionManager.getConnection();
stmt = conn.createStatement();
rs = stmt.executeQuery("select * from seller where seller_power='2'");
while(rs.next()){
SellerForm sf = new SellerForm();
sf.setSeller_name(rs.getString("seller_name"));
sf.setSeller_psw(rs.getString("seller_psw"));
sf.setSeller_power(rs.getString("seller_power"));
sf.setSeller_id(rs.getString("seller_id"));
list.add(sf);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.closeConnection(conn);
}
return list;
}
public static List findId(String id){
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
List list = new ArrayList();
try{
stmt = conn.createStatement();
rs = stmt.executeQuery("select * from seller where seller_id='"+id+"'");
while(rs.next()){
SellerForm sf = new SellerForm();
sf.setSeller_id(rs.getString("seller_id"));
sf.setSeller_name(rs.getString("seller_name"));
sf.setSeller_power(rs.getString("seller_power"));
sf.setSeller_psw(rs.getString("seller_psw"));
list.add(sf);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return list;
}
//2,删除
public static int delete(String id){
Connection conn = null;
Statement stmt = null;
int flag = 0;
try{
conn = ConnectionManager.getConnection();
stmt = conn.createStatement();
flag = stmt.executeUpdate("delete seller where seller_id='"+id+"'");
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return flag;
}
//3,修改
public static int update(String id,String name,String psw){
Connection conn = null;
Statement stmt = null;
int n = 0;
try{
stmt = conn.createStatement();
n = stmt.executeUpdate("update seller set seller_name='"+name+"',seller_psw='"+psw+"' where seller_id="+id);
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return n;
}
//4,插入
public static int insert(String name,String psw){
Connection conn = null;
Statement stmt = null;
int i = 0;
try{
stmt = conn.createStatement();
i = stmt.executeUpdate("insert into seller (select max(seller_id)+1 ,"+name+","+psw+",'2' from seller)");
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return i;
}
//处理登录这个模块
public static String login(String name,String psw,Connection conn){
Statement stmt = null;
ResultSet rs = null;
String power = "";
try{
stmt = conn.createStatement();
rs = stmt.executeQuery("select * from seller where seller_name='"+name+"' and seller_psw='"+psw+"'");
//如果查询出姓名密码来了就获取权限值
if(rs.next()){
power = rs.getString("seller_power");
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return power;
}
/*针对custom表*/
//1,查询
public static List findAllCustom(Connection conn){
Statement stmt = null;
ResultSet rs= null;
String sql1 = "";
String sql2 = "";
List list = new ArrayList();
try{
stmt=conn.createStatement();
sql1 = "select seller_name,customer_name,customer_sex,customer_email,customer_phone ";
sql2 = "from customer,seller where customer.seller_id=seller.seller_id and customer_state='1'";
rs = stmt.executeQuery(sql1+sql2);
while(rs.next()){
CustomForm c = new CustomForm();
c.setSeller_name(rs.getString("seller_name"));
c.setCustomer_name(rs.getString("customer_name"));
c.setCustomer_sex(rs.getString("customer_sex"));
c.setCustomer_email(rs.getString("customer_email"));
c.setCustomer_phone(rs.getString("customer_phone"));
list.add(c);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return list;
}
public static List dispaterSeller(Connection conn){
Statement stmt = null;
ResultSet rs = null;
List list = new ArrayList();
try{
stmt = conn.createStatement();
String sql = "select * from seller where seller_power='2'";
rs = stmt.executeQuery(sql);
while(rs.next()){
SellerForm sf = new SellerForm();
sf.setSeller_name(rs.getString("seller_name"));
sf.setSeller_id(rs.getString("seller_id"));
list.add(sf);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return list;
}
public static List dispaterCustom(Connection conn){
Statement stmt = null;
ResultSet rs = null;
List list = new ArrayList();
try{
stmt = conn.createStatement();
String sql = "select * from customer where customer_state='0'";
rs = stmt.executeQuery(sql);
while(rs.next()){
CustomForm cf = new CustomForm();
cf.setCustomer_name(rs.getString("customer_name"));
cf.setCustomer_id(rs.getString("customer_id"));
list.add(cf);
}
}catch(Exception e){
e.printStackTrace();
}finally{
ConnectionManager.getConnection();
}
return list;
}
public static void dispater(String sid,String cid,Connection conn,int count,int i){
Statement stmt = null;
try{
stmt = conn.createStatement();
stmt.executeUpdate("update customer set seller_id='"+sid+"',customer_state='1' where customer_id ="+cid);
}catch(Exception e){
e.printStackTrace();
}finally{
if(count==i){
ConnectionManager.getConnection();
}
}
}
}
分享到:
相关推荐
jdbc连接数据库 jdbc连接数据库 jdbc连接数据库 jdbc连接数据库 jdbc连接数据库
JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试JDBC连接数据库测试...
JAVA-JDBC连接数据库(查询_添加_修改_删除)
jdbc连接数据库方法大全,提供了各种jdbc连接数据库的方法,让你明了哪种方法更高效
JDBC连接数据库步骤及代码,不适合初学者
jdbc连接数据库的步骤,适合初学者,网上都有,但是可以下载去看看
JDBC连接数据库代码大全,有各种连接数据库的方法。
各种数据库的连接文档JDBC连接数据库经验总结
jdbc java 数据库 连接数据库 步骤
Jdbc连接数据库的方法 附上一个简单例子 详细说明
里面详细记录了JDBC连接数据库方法的文档,并附有示例
选课序号:36 选课序号:36 大连海事大学 数据库原理课程实验报告 (2010-2011学年第二学期) 实验八 JDBC连接数据库 班 级: 智能一班 学 号: ********** 姓 名: 徐维坚 指导教师: *** 成 绩: 2012年 6月 13日 ...
java实例jdbc连接数据库大全.doc
这是我总结的jdbc连接数据库事务工厂模式的例子在项目中经常用,很不错的。
使用java,jdbc连接数据库和Java swing图形化界面完成一个商品管理系统.zip 大学生课程设计 基于Java的课程设计 自己大二写的课程设计
JDBC连接数据库工具类 JDBC 连接数据库 ORACLE SQLSERVER MYSQL ORACLE 已测 OK 欢迎大家反馈 我的微博是: http://weibo.com/namenode
JDBC连接数据库及增删查改基本步骤,仅供Java新手参考
常用的jdbc连接数据库架包jar,包括oracle DB2 SqlServer mysql等
JDBC连接数据库JDBC连接数据库