db.java

我的博客

package com.yxq.toolsbean;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DB
{
/*	当使用 jdbc 连接时 有用
 * 	private final String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=db_Blog";
	private final String userName = "sa";
	private final String password = "";*/
	
	private Connection con = null;
	private Statement stm = null;  // 执行 SQL 语句 接口

	/* 通过构造方法加载数据库驱动 */
	public DB()
	{
		try
		{
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
		} catch (Exception e)
		{
			e.printStackTrace();
			System.out.println("加载数据库驱动失败！");
		}
	}

	/* 创建数据库连接 */
	public void createCon()
	{
		try
		{
			con = DriverManager.getConnection("jdbc:odbc:student");
		} catch (Exception e)
		{
			e.printStackTrace();
			System.out.println("获取数据库连接失败！");
		}
	}

	/* 获取Statement对象 */
	public void getStm()  
	{
		createCon();  // 创建数据库
		try
		{
			stm = con.createStatement();
		} catch (SQLException e)
		{
			e.printStackTrace();
			System.out.println("创建Statement对象失败！");
		}
	}

	/** 
	 * @功能 对数据库的 增加、修改 和 删除的操作
	 * @参数 sql为要执行的SQL语句
	 * @返回值 boolean型值 
	 */
	public boolean executeUpdate(String sql)  // 是否执行 
	{
		System.out.println(sql);
		boolean mark = false;
		try
		{
			getStm();  // 获取 statement 对象
			int iCount = stm.executeUpdate(sql);  // 获得 记录 条数
			if (iCount > 0)
				mark = true;
			else
				mark = false;
		} catch (Exception e)
		{
			e.printStackTrace();
			mark = false;
		}
		return mark;
	}

	/* 查询数据库 */
	public ResultSet executeQuery(String sql)
	{
		ResultSet rs = null;
		try
		{
			getStm();
			try
			{
				rs = stm.executeQuery(sql);
			} catch (Exception e)
			{
				e.printStackTrace();
				System.out.println("查询数据库失败！");
			}
		} catch (Exception e)
		{
			e.printStackTrace();
		}
		return rs;
	}

	/* 关闭数据库的操作 */
	public void closed()
	{
		if (stm != null)
			try
			{
				stm.close();
			} catch (SQLException e)
			{
				e.printStackTrace();
				System.out.println("关闭stm对象失败！");
			}
		if (con != null)
			try
			{
				con.close();
			} catch (SQLException e)
			{
				e.printStackTrace();
				System.out.println("关闭con对象失败！");
			}
	}
}