www.pudn.com > zhaobiao.rar > NewMaker.java
/**
*
*/
package com.centralsoft.zhaobiao.admin;
import java.util.*;
import java.sql.*;
import com.centralsoft.zhaobiao.util.*;
import com.centralsoft.zhaobiao.qtdataguanli.*;
import com.centralsoft.zhaobiao.admin.*;
/**
* @author zw
*
*/
public class NewMaker {
public NewMaker() {
}
long NewMaker_id;
int certificateCount;
String NewMaker_name;
String NewMaker_address;
String NewMaker_cr_address;
String NewMaker_cr_time;
String NewMaker_cr_cost;
String NewMaker_fr_name;
String NewMaker_fr_position;
String NewMaker_attribute;
String NewMaker_relation;
String NewMaker_db_content;
/**
* 设置新添加后的厂商id
* @param NewMaker_id
*/
public void setNewMaker_id(long NewMaker_id) {
this.NewMaker_id = NewMaker_id;
}
/**
* 返回新添加后的厂商id
* @return
*/
public long getNewMaker_id() {
return NewMaker_id;
}
public void setNewMaker_name(String NewMaker_name) {
this.NewMaker_name = NewMaker_name;
}
public String getNewMaker_name() {
return NewMaker_name;
}
public void setNewMaker_address(String NewMaker_address) {
this.NewMaker_address = NewMaker_address;
}
public String getNewMaker_address() {
return NewMaker_address;
}
public void setNewMaker_cr_address(String NewMaker_cr_address) {
this.NewMaker_cr_address = NewMaker_cr_address;
}
public String getNewMaker_cr_address() {
return NewMaker_cr_address;
}
/**
* 验证厂商是否更新成功
* 1代表更新成功，0代表更新失败
* @param certificateCount
*/
public void setCertificateCount(int certificateCount) {
this.certificateCount = certificateCount;
}
/**
* 返回验证厂商是否更新成功的值
* @return
*/
public int getCertificateCount() {
return certificateCount;
}
/**
* 验证新添加(或删除)的厂商id是不是存在于数据库中
* 1代表添加成功，0代表删除成功
* @return
*/
public int certificateMaker_id() {
int count = 0;
long maxid = getNewMaker_id();
dataBase db = new dataBase();
ResultSet rs = null;
String sql = "select * from maker where maker_id = "+maxid;
rs = db.getResultSet(sql);
try {
while (rs.next()) {
count ++;
}
System.out.println("验证新添加(或删除)的厂商id是不是存在于数据库中:"+count);
} catch (Exception e) {
System.out.println(e.getMessage());
} finally {
try {
if (rs != null) {
rs.close();
}
db.closeConn();
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
return count;
}
/**
* 添加厂商
* @param mk
*/
public void addMaker(Maker mk) {
long maxid = 0;
Connection conn = null;
dataBase db = new dataBase();
conn = db.getConnection();
String sql = "select max(maker_id) as id from maker";
PreparedStatement ps = null;
PreparedStatement ps1 = null;
ResultSet rs1 = null;
try {
ps1 = conn.prepareStatement(sql);
rs1 = ps1.executeQuery();
if (rs1.next()) {
maxid = rs1.getLong("id") + 1;
System.out.println("生成的厂商id====="+maxid);
} else {
maxid = 1;
}
setNewMaker_id(maxid);//将新添加后的厂商id
} catch (Exception e) {
System.out.println(e.getMessage());
} finally {
try {
if (rs1 != null) {
rs1.close();
}
if (ps1 != null) {
ps1.close();
}
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
String sqlAdd = "insert into maker (maker_id,maker_name,maker_address,maker_cr_time," +
"maker_cr_address,maker_cr_cost,maker_fr_name,maker_fr_position,maker_attribute,maker_relation,maker_db_content) " +
"values (?,?,?,?,?,?,?,?,?,?,?)";
try {
ps = conn.prepareStatement(sqlAdd);
ps.setLong(1,maxid);
ps.setString(2,mk.getMaker_name());
ps.setString(3,mk.getMaker_address());
ps.setString(4,mk.getMaker_cr_time());
ps.setString(5,mk.getMaker_cr_address());
ps.setString(6,mk.getMaker_cr_cost());
ps.setString(7,mk.getMaker_fr_name());
ps.setString(8,mk.getMaker_fr_position());
ps.setString(9,mk.getMaker_attribute());
ps.setString(10,mk.getMaker_relation());
ps.setString(11,mk.getMaker_db_content());
ps.executeUpdate();
} catch (Exception e) {
System.out.println(e.getMessage());
} finally {
try {
if (ps != null) {
ps.close();
}
db.closeConn();
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
}
/**
* 更新一个厂商信息
* @param mk
*/
public void updateMaker(Maker mk) {
Connection conn = null;
dataBase db = new dataBase();
conn = db.getConnection();
String sql = "update maker set maker_name = ?,maker_address = ?,maker_cr_time = ?,maker_cr_address = ?," +
"maker_cr_cost = ?,maker_fr_name = ?,maker_fr_position = ?,maker_attribute = ?,maker_relation = ?," +
"maker_db_content = ? where maker_id = ?";
PreparedStatement ps = null;
try {
ps = conn.prepareStatement(sql);
ps.setString(1,mk.getMaker_name());
ps.setString(2,mk.getMaker_address());
ps.setString(3,mk.getMaker_cr_time());
ps.setString(4,mk.getMaker_cr_address());
ps.setString(5,mk.getMaker_cr_cost());
ps.setString(6,mk.getMaker_fr_name());
ps.setString(7,mk.getMaker_fr_position());
ps.setString(8,mk.getMaker_attribute());
ps.setString(9,mk.getMaker_relation());
ps.setString(10,mk.getMaker_db_content());
ps.setLong(11,mk.getMaker_id());
ps.executeUpdate();
} catch (Exception e) {
System.out.println(e.getMessage());
} finally {
try {
if (ps != null) {
ps.close();
}
conn.close();
db.closeConn();
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
String sqlCertificate = "select * from maker where (maker_id = '"+mk.getMaker_id()+"') " +
"and (maker_name = '"+mk.getMaker_name()+"'or maker_address = '"+mk.getMaker_address()+"" +
"'or maker_cr_time = '"+mk.getMaker_cr_time()+"'or maker_cr_address = '"+mk.getMaker_cr_address()+"" +
"'or maker_cr_cost = '"+mk.getMaker_cr_cost()+"'or maker_fr_name = '"+mk.getMaker_fr_name()+"" +
"'or maker_fr_position = '"+mk.getMaker_fr_position()+"'or maker_attribute = '"+mk.getMaker_attribute()+"" +
"'or maker_relation = '"+mk.getMaker_relation()+"'or maker_db_content = '"+mk.getMaker_db_content()+"')";
ResultSet rs1 = null;
System.out.println("sqlCertificate====="+sqlCertificate);
int count = 0;
rs1 = db.getResultSet(sqlCertificate);
try {
while (rs1.next()) {
count ++;
}
setCertificateCount(count);
System.out.println("返回验证厂商是否更新成功的值:"+count);
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
/**
* 根据厂商的id删除厂商，并且删除procduct表中该厂商的所有产品信息。
* （其中在删除该产品时会删除ppm表中的所有与该产品相关的记录，
* 同时删除ppm记录时会删除与ppm记录对应的price记录）
* @param maker_id
*/
public void delMaker(long maker_id) {
Connection conn = null;
dataBase db = new dataBase();
conn = db.getConnection();
String sql = "delete from maker where maker_id = ?";
PreparedStatement ps = null;
try {
ps = conn.prepareStatement(sql);
ps.setLong(1,maker_id);
ps.executeUpdate();
NewProduct newpd = new NewProduct();
newpd.delProductMakerid(maker_id);
} catch (Exception e) {
System.out.println(e.getMessage());
} finally {
try {
if (ps != null) {
ps.close();
}
db.closeConn();
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
}
}