userdao.java

新东方软件开发项目

package com.mobile.dao;

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

import com.mobile.bean.TUser;

public class UserDAO {
	public int addUser(TUser user) {
		int ret = 0;
		Connection con = null;
		PreparedStatement pstmt = null;
		PreparedStatement pstmt1 = null;
		PreparedStatement pstmt2 = null;
		ResultSet rs = null;
		try {
			con = ConnectionMgr.getConnection();

			String sql = "select sum(charge) from TCharge where charge_code in(select charge_code from TCharge_Rule where func_id='O')";
		
			pstmt1 = con.prepareStatement(sql);
			rs = pstmt1.executeQuery();
			while (rs.next()) {
				ret = rs.getInt(1);
				System.out.println(ret + "as");
			}
			String sql1 = "update TAccount set Account_Balance=Account_Balance - "+ret+" where  account_id="+user.getAccountId();
			System.out.println(sql1);
			pstmt2 = con.prepareStatement(sql1);
			 pstmt2.executeUpdate();
			pstmt = con.prepareStatement("insert into TUser(user_id,mobile_number,roaming_status,com_level,customer_id,account_id) values(user_sequence.nextval,?,?,?,?,?)");
			System.out.println(sql);
			System.out.println((int) user.getAccountId());
			System.out.println((int) user.getAccountId());
			System.out.println((int) user.getCustomerId());
			pstmt.setString(1, user.getMobileNumber());
			pstmt.setString(2, Character.toString(user.getRoamingStatus()));
			pstmt.setString(3, Character.toString(user.getComLevel()));
			pstmt.setInt(4, (int) user.getCustomerId());
			pstmt.setInt(5, (int) user.getAccountId());

			pstmt.executeUpdate();
      
		

		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println(ret);
		return ret;
	}
}