db.java

在一个大的项目中建立小的子应用,这样就可以一个项目同时有几个小分队开发.可以完成子应用的相互调用.

package ups;

import java.sql.*;//为了能使用数据库，我们加载了数据库包
import java.util.ArrayList;

public class DB {
	private Connection conn;// 用来连接数据库的“数据库连接对象”

	private PreparedStatement stmt;// 数据库操作对象

	private ResultSet rs;// 结果集

	public DB() {
		try {

			conn = DBPool.getPool().getConnection();// 使用连接池创建连接
		} catch (Exception e) {

		}
	}
	public boolean login(String username,String password)
	{
		boolean b=false;
		try {
			stmt=conn.prepareStatement("select count(*) from users where username=? and password=?");
			stmt.setString(1, username);
			stmt.setString(2, password);
			rs=stmt.executeQuery();
			rs.next();//????
			if(rs.getInt(1)>0)
				b=true;//表示登录成功
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return b;
	}
	public boolean ckreg(String username,String password)
	{
		boolean a=false;//false表示注册失败
		/*
		 * 先判断用户名是否可用，如果可用，马上给它注册（其实就是insert语句），并返回真值
		 * 如果发现不可用，就直接返回假值
		 * */
		try {
			stmt=conn.prepareStatement("select count(*) from users where username=?");
			stmt.setString(1, username);
			rs=stmt.executeQuery();
			rs.next();//结果集默认指针位置不是第一行，而是第一行的上面，所以在这里我们要调整一下指针的位置
			int x=rs.getInt(1);
			rs=null;
    		if(x<1)
			{
				//表示用户名可以使用
    			stmt=conn.prepareStatement("insert into users(username,password)values(?,?)");
    			stmt.setString(1, username);
    			stmt.setString(2, password);
    			stmt.execute();
    			a=true;//表示注册成功
			}
    		conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return a;
	}
	public void savemusic(String oldname,String newname,String info)
	{
		try {
			stmt=conn.prepareStatement("insert into music(oldname,newname,info) values(?,?,?)");
			stmt.setString(1, oldname);
			stmt.setString(2, newname);
			stmt.setString(3, info);
			stmt.execute();
			conn.close();
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	public ArrayList allmusic()
	{
		ArrayList a=new ArrayList();
		try {
			stmt=conn.prepareStatement("select * from music order by id desc");
			rs=stmt.executeQuery();
			while(rs.next())
			{
				Music m=new Music();
				m.setInfo(rs.getString("info"));
				m.setNewname(rs.getString("newname"));
				m.setOldname(rs.getString("oldname"));
				a.add(m);
			}
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return a;
	}
}