users.java

新闻管理系统实现对新闻添加修改删除外挂了一个用户的注册还有一个外挂的投票

package com.vsked.services;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import com.vsked.javaBean.*;
import com.vsked.models.ConnectDB;

public class Users {
	private boolean flag;
	private Connection conn;
	private PreparedStatement pt;
	private ResultSet rs;
	private ArrayList results;
	
	
	//添加用户
	public boolean  adduser(com.vsked.javaBean.UsersBean us){
		int row=0;
		conn=ConnectDB.getConnectionJDBC();
	    try {
			pt=conn.prepareStatement("insert into users values(?,?,?)");
			pt.setString(1,us.getUid());
			pt.setString(2, us.getUname());
			pt.setString(3, us.getUpwd());
			row=pt.executeUpdate();
			if(row>0){
				flag=true;
			}			
		} catch (SQLException e) {		
		}finally{
			ConnectDB.close();
		}
		
		return flag;
	}
	
	//查询所有用户信息
	public ArrayList getAllUserInfo(){
		results=new ArrayList();
		conn=ConnectDB.getConnectionJDBC();
	    try {
			pt=conn.prepareStatement("select userid,username,userpwd from users");			
			rs=pt.executeQuery();
			while(rs.next()){				
				results.add(new com.vsked.javaBean.UsersBean(rs.getString(1),rs.getString(2),rs.getString(3)));
			}
			flag=true;			
		} catch (Exception e) {
		
		}finally{
			ConnectDB.close();
		}		
		return results;
	}
	
	//查询单个用户信息
	public UsersBean getUserInfoByUserId(String uid){
		UsersBean us = null;
		conn=ConnectDB.getConnectionJDBC();
	    try {
			pt=conn.prepareStatement("select userid,username,userpwd from users where userid=?");
			pt.setString(1, uid);
			rs=pt.executeQuery();
			if(rs.next()){				
				us=new com.vsked.javaBean.UsersBean(rs.getString(1),rs.getString(2),rs.getString(3));
			}
			flag=true;			
		} catch (Exception e) {
		
		}finally{
			ConnectDB.close();
		}		
		return us;
	}
	
	//修改用户
	public boolean modifyuser(com.vsked.javaBean.UsersBean user){
		int row=0;
		conn=ConnectDB.getConnectionJDBC();
	    try {
			pt=conn.prepareStatement("update users set username=?,userpwd=? where userid=?");
			pt.setString(1, user.getUname());
			pt.setString(2, user.getUpwd());
			pt.setString(3, user.getUid());			
			row=pt.executeUpdate();
			if(row>0){
				flag=true;
			}		
			
		} catch (SQLException e) {	
			
		}finally{
			ConnectDB.close();
		}
		
		return flag;
	}

	public boolean isExistUserId(String uid){
		conn=ConnectDB.getConnectionJDBC();
	    try {
			pt=conn.prepareStatement("select userid from users where userid=?");			
			pt.setString(1, uid);
			rs=pt.executeQuery();
			if(rs.next()){
    			flag=true;		
			}				
		} catch (Exception e) {
		
		}finally{
			ConnectDB.close();
		}		
		return flag;		
	}
}