bankmodle.java

来自「用java 语言开发的webservice源代码 包含webservice的发」· Java 代码 · 共 69 行

package org.accp.DAO;

import org.accp.Entity.*;

import java.util.ArrayList;
import java.util.List;
import java.sql.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

public class BankModle {

	private PreparedStatement pstmt;
	private ResultSet rs;
	private Connection conn;
	
	public List<CustomerBean> getCustomers(){
		List<CustomerBean> itmes=new ArrayList();
		try{
		Context ic=new InitialContext();
		DataSource source=(DataSource)ic.lookup("java:comp/env/jdbc/bank");
		conn=source.getConnection();
		}catch(Exception ex){
			ex.printStackTrace();
			System.out.println("连接数据库出错！");
		}
		try{
		pstmt=conn.prepareStatement("select * from userInfo");
		rs=pstmt.executeQuery();
		while(rs.next()){
			CustomerBean coustomer=new CustomerBean();
			coustomer.setUserID(rs.getString("userID"));
			coustomer.setUsername(rs.getString("userName"));
			coustomer.setBalance(rs.getDouble("balance"));
			
//			System.out.println(rs.getString("userID"));
//			System.out.println(rs.getString("userName"));
//			System.out.println(rs.getDouble("balance"));
			
			itmes.add(coustomer);
		}
		}catch(Exception e){
			e.printStackTrace();
			System.out.println("查询语句有错!");
		}
		return itmes;
	}
	
	
	public double getall(String userid){
		try{
			Context ic=new InitialContext();
			DataSource source=(DataSource)ic.lookup("java:comp/env/jdbc/bank");
			conn=source.getConnection();
			pstmt=conn.prepareStatement("select * from userInfo where userID=?");
			pstmt.setString(1, userid);
			rs=pstmt.executeQuery();
			while(rs.next()){
				return rs.getDouble("balance");
			}
			}catch(Exception ex){
				ex.printStackTrace();
				System.out.println("连接数据库出错！");
			}
			return 0;
	}
}