infordata.java

本软件是一个规模较大网上货物购买管理系统

package data;

import java.sql.*;

public class InforData {
	//取得数据库连接的方法
	public Connection setupConn(){
		try{
			//定义MYSQL的数据库连接驱动类
			String mySqlDrive="org.git.mm.mysql.Driver";
			//定义MYSQL的连接地址
			String url="jdbc:mysql://localhost:3306/furniture?user=root;password=123123";
			//使用JDBDC桥创建数据库连接
			Class.forName(mySqlDrive);
			//使用DriveManager类的getConnection()方法建立连接，
			//第一个字符参数定用户名，第二字符参数定义密码
			Connection conn=DriverManager.getConnection(url,"","");
			return conn;
		}catch(Exception e){
			e.printStackTrace();
			return null;
		}
	}
	//取得产品类别数据的方法
	public String[][] showCategory(){
		//创建存取产品类别数据表数据的数组
		String[][] categories=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			String sql="select count(*) from category";
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				categories=new String[rowCount][3];
				sql="select * from category";
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//取得类别ID
					categories[row][0]=rs.getString(1);
					//取得类别名
					categories[row][1]=rs.getString(2);
					//取得类别描述
					categories[row][2]=rs.getString(3);
					row++;
				}
			}else{
				categories=new String[1][1];
				categories[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接；
		closeConn(conn);
		return categories;
	}
	//根据产品类别取得产品数据的方法
	public String[][]showProduct(int categoryId){
		//创建存取产品数据表数据的数组
		String[][] products=null;
		//创建Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			String sql="select count(*) from product where categoryId =" + categoryId;
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				products=new String[rowCount][9];
				sql="select * from product where categoryId = " +categoryId;
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//将product数据表的数据放入products数组
					for(int i=0;i<9;i++){
						products[row][i]=rs.getString(i+1);
					}
					row++;
				}
			}else{
				products=new String[1][1];
				products[0][0]="没有产品数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return products;
	}
	//取得产品类别数据表数据的数组
	public String[][]getCategory(){
		//创建存取产品类别数据表数据的数组
		String[][] categories=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			String sql="select count(*) from category";
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				categories=new String[rowCount][3];
				sql="select * from category";
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//取得类别ID
					categories[row][0]=rs.getString(1);
					//取得类别名字
					categories[row][1]=rs.getString(2);
					//取得类别描述
					categories[row][2]=rs.getString(3);
					row++;
				}
			}else{
				categories=new String[1][1];
				categories[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return categories;
	}
	//根据产品类别名称或者描述取得产品类别数据的方法
	public String[][] getCategoryByField(String fieldName,String name){
		//创建存取产品类别数据表数据的数组
		String[][] categories=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			String sql="select count(*) from category where"+ fieldName +"like ?";
			//创建sql语句执行类
			PreparedStatement pstmt=conn.prepareStatement(sql);
			//设置执行类的参数
			pstmt.setString(1,"%"+ name + "%");
			//取得记录
			ResultSet rs=pstmt.executeQuery();
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				categories=new String[rowCount][3];
				sql="select * from category where"+fieldName+"like ?";
				//创新创建执行类
				pstmt.setString(1,"%"+name+"%");
				//设置执行类的参数
				rs=pstmt.executeQuery();
				int row=0;
				while(rs.next()){
					//取得类别ID
					categories[row][0]=rs.getString(1);
					//取得类别名字
					categories[row][1]=rs.getString(2);
					//取得类别描述
					categories[row][2]=rs.getString(3);
					row++;
				}
			}else{
				categories=new String[1][1];
				categories[0][0]="没有产品类别数据.";
			}
			pstmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return categories;
		}
    //根据产品类别取得产品类别数据的方法
	public String[][] getProductByCategoryId(int categoryId)
	{
		//创建存取产品类别数据表数据的数组
		String[][] products=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			//设置执行类的参数
			String sql="select count(*) from product where categoryId="+categoryId;
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				products=new String[rowCount][9];
				sql="select * from product where categoryId="+categoryId;
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//将product数据表的数据放入products数组
					for(int i=0;i<9;i++){
						products[row][i]=rs.getString(i+1);
					}
					row++;
				}
			}else{
				products=new String[1][1];
				products[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return products;
		}
    //根据产品类别取得产品类别数据的方法
	public String[][] getProductByName(String name)
	{
		//创建存取产品类别数据表数据的数组
		String[][] products=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			//设置执行类的参数
			String sql="select count(*) from product where name like'%"+name+"%'";
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				products=new String[rowCount][9];
				sql="select * from product where name like'%"+name+"%'";
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//将product数据表的数据放入products数组
					for(int i=0;i<9;i++){
						products[row][i]=rs.getString(i+1);
					}
					row++;
				}
			}else{
				products=new String[1][1];
				products[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return products;
		}
    //根据数字字段取得产品数据的方法
	public String[][] getProductByNum(int compareSymbol,String fieldName,double num)
	{
		//创建比较字符串数组
		String[] compareSymbols={"=",">",">=","<","<="};
		//创建存取残品数据表数据的数组
		String[][] products=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			//设置执行类的参数
			String sql="select count(*) from product where "+fieldName
			+compareSymbols[compareSymbol]+num;
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				products=new String[rowCount][9];
				sql="select count(*) from product where "+fieldName
				+compareSymbols[compareSymbol]+num;
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//将product数据表的数据放入products数组
					for(int i=0;i<9;i++){
						products[row][i]=rs.getString(i+1);
					}
					row++;
				}
			}else{
				products=new String[1][1];
				products[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return products;
		}
	   //根据是否可用字段取得产品数据的方法
	public String[][] getProductByIsUsed(double isUsed)
	{
        //创建存取产品数据表数据的数组
		String[][] products=null;
		//取得Infor数据库的连接
		Connection conn=setupConn();
		int rowCount=0;
		try{
			//创建sql语句执行类
			Statement stmt=conn.createStatement();
			String sql="select count(*) from product where isUsed"+isUsed;
			ResultSet rs=stmt.executeQuery(sql);
			//取得总记录数
			if(rs.next()){
				rowCount=rs.getInt(1);
			}
			if(rowCount>0){
				//根据总记录数创建数组
				products=new String[rowCount][9];
				sql="select count(*) from product where isUsed"+isUsed;
				rs=stmt.executeQuery(sql);
				int row=0;
				while(rs.next()){
					//将product数据表的数据放入products数组
					for(int i=0;i<9;i++){
						products[row][i]=rs.getString(i+1);
					}
					row++;
				}
			}else{
				products=new String[1][1];
				products[0][0]="没有产品类别数据.";
			}
			stmt.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
		//关闭数据库的连接
		closeConn(conn);
		return products;
		}
    //关闭数据库连接的方法
	public void closeConn(Connection conn){
		try{
			conn.close();
		}catch(Exception ex){
			ex.printStackTrace();
		}
	}
}