updatepesticidebean.java

该系统具体分为2个部分：前台和后台。 1．前台主要用于用户进行浏览和搜索

package ynuBean;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class UpdatePesticideBean {
	private String msg;

	private String detail;

	public UpdatePesticideBean() {

	}

	public String AddPesticide(String PID, String Pname, String tox,
			String cha, float price, int qty) {
		try {
			ConnectDataBase aConnect = new ConnectDataBase();
			Connection con = aConnect.getconnection();
			Statement sqlstatement = con.createStatement();
			// 查找用户的余额
			String insert = "insert into Pesticide" + " values('" + PID + "','"
					+ Pname + "','" + tox + "','" + cha + "'," + price + ","
					+ qty + ")";
			sqlstatement.executeUpdate(insert);

			msg = "添加成功";
			con.close();
		} catch (SQLException e) {
			System.out.println(e.toString());
			msg = "添加失败";
		} catch (Exception e) {
			System.out.println(e.toString());
			msg = "添加失败";
		}

		return msg;
	}

	public String DeletePesticide(String Pid) {
		try {
			ConnectDataBase aConnect = new ConnectDataBase();
			Connection con = aConnect.getconnection();
			Statement sqlstatement = con.createStatement();
			// 查找用户的余额
			String delete = "delete from pesticide where PID='" + Pid + "'";
			sqlstatement.executeUpdate(delete);

			msg = "删除成功";
			con.close();
		} catch (SQLException e) {
			System.out.println(e.toString());
			msg = "删除失败";
		} catch (Exception e) {
			System.out.println(e.toString());
			msg = "删除失败";
		}

		return msg;
	}

	public Pesticide getPesticide(String Pid) {
		Pesticide aPesticide = null;
		try {
			ConnectDataBase aConnect = new ConnectDataBase();
			Connection con = aConnect.getconnection();
			Statement sqlstatement = con.createStatement();
			String query = "Select * from Pesticide where PID='" + Pid + "'";

			ResultSet result = sqlstatement.executeQuery(query);

			while (result.next()) {
				String PID = result.getString("PID");
				String Pname = result.getString("Pname");
				String toxicity = result.getString("toxicity");
				String character = result.getString("charachter");
				float price = result.getFloat("price");
				int qty = result.getInt("qty");
				aPesticide = new Pesticide(PID, Pname, toxicity, character,
						price, qty);
			}

			String query1 = "select * from pdetail where PID='" + Pid + "'";
			ResultSet rs = sqlstatement.executeQuery(query1);

			while (rs.next()) {
				detail = rs.getString("description");
			}
			con.close();
		} catch (SQLException e) {
			System.out.println(e.toString());
		} catch (Exception e) {
			System.out.println(e.toString());
		}
		return aPesticide;
	}

	public String getDetail() {
		return detail;
	}

	public String EditPesticide(String PID, String Pname, String tox,
			String cha, float price, int qty,String detail) 
	{
		try {
			ConnectDataBase aConnect = new ConnectDataBase();
			Connection con = aConnect.getconnection();
			Statement sqlstatement = con.createStatement();
			// 查找用户的余额
			String update1 = "update pesticide set Pname='"+Pname+"' " +
					"where PID='"+PID+"'";
			sqlstatement.executeUpdate(update1);
			
			String update2 = "update pesticide set toxicity='"+tox+"' " +
			"where PID='"+PID+"'";
			sqlstatement.executeUpdate(update2);
			
			String update3 = "update pesticide set charachter='"+cha+"' " +
			"where PID='"+PID+"'";
			sqlstatement.executeUpdate(update3);
	
			String update4 = "update pesticide set price="+price+" " +
							"where PID='"+PID+"'";
			sqlstatement.executeUpdate(update4);
			
			String update5 = "update pesticide set qty="+qty+" " +
			"where PID='"+PID+"'";
			sqlstatement.executeUpdate(update5);
			
			String query = "select * from pdetail where PID='"+PID+"'";
			ResultSet rs = sqlstatement.executeQuery(query);
			
			if(rs.next())
			{
				String update6 = "update pdetail set description="+detail+" " +
									"where PID='"+PID+"'";
				sqlstatement.executeUpdate(update6);
			}
			else
			{
				String insert = "insert pdetail (PID,description) " +
						"values('"+PID+"','"+detail+"')";
				sqlstatement.executeUpdate(insert);
			}
			
			msg = "更新成功";
			con.close();
		} catch (SQLException e) {
			System.out.println(e.toString());
			msg = "更新失败";
		} catch (Exception e) {
			System.out.println(e.toString());
			msg = "更新失败";
		}

		return msg;
	}

}