usersqldaoimpl.java

开发的一个java web的任务管理系统。

/**
 * 
 */
package unicom.dao;

import unicom.bean.User;
import java.sql.*;

import unicom.util.*;
/**
 * @author 陈才旭
 * 日期：Apr 16, 2008
 * 功能：实现接口IUserDao,实现对数据库的具体访问
 * 优点：降低耦合，容易控制
 * 缺点：
 * 建议：
 */
public class UserSqlDaoImpl implements IUserDao{
	
	//向数据库插入一条手机用户记录,需要用到事务处理
	public boolean addUser(User u) {
		boolean flag = false;
		String number = u.getNumber();
		String status = u.getStatus();
		String level = u.getLevel();
		String customer_Id = u.getCustomerId();
		String sql = "insert into TUser(id,number,status,level,customer_Id) values(null,?,?,?,?)";
	    String sql2 = "update TMobile set isAvailable = 'N' where number = ?";
		Connection conn = DBUtil.getConn();
		PreparedStatement pstmt = null;
		
		try {
			//增加记录
			boolean autoCommit = conn.getAutoCommit();//保留现场
			conn.setAutoCommit(false);//将其设置为不自动提交
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, number);
			pstmt.setString(2, status);
			pstmt.setString(3, level);
			pstmt.setInt(4, Integer.parseInt(customer_Id));
			pstmt.execute();
		    //同时将该手机号码设为不可用
			pstmt = conn.prepareStatement(sql2);
			pstmt.setString(1, number);
			pstmt.execute();
			//事务提交
			conn.commit();
			//恢复现场
			conn.setAutoCommit(autoCommit);
			flag = true;
		} catch (SQLException e) {
			e.printStackTrace();
			try {
				conn.rollback();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
			flag = false;
		}finally{
			//释放资源
			DBUtil.close(conn);
			DBUtil.close(pstmt);
		}
		return flag;
	}

}