operatedatabase.java

很好的东东 本人随便做的 仅供学习之用

package chuyun.javabeans;
import cangku.action;


import java.sql.*;

public class OperateDataBase {
	private Connection conn = null;

	private PreparedStatement ps = null;

	private ResultSet rs = null;

	private Statement st = null;

	public OperateDataBase() {

	}

	public int insertsends(String sql) {

		int i = 0;
		try {
			conn = ConnManager.getMyconn();
			Statement st = conn.createStatement();
			System.out.println(sql);
			i = st.executeUpdate(sql);

			st.close();
			conn.close();
		} catch (SQLException ex) {
			ex.printStackTrace();
		}

		return i;
	

	}

	//插入、删除、更新数据库操作
	public int updateDataBase(String sqlVal) {
		conn = ConnManager.getMyconn();
		int i = 0;
		try {
			ps = conn.prepareStatement(sqlVal);
			i = ps.executeUpdate();
			ps.close();
			conn.close();
		} catch (SQLException ex) {
			ex.printStackTrace();
		}
		return i;
	}

	//根据sql语句获取ResultSet
	public ResultSet getMyResultSet(String sqlVal) {
		conn = ConnManager.getMyconn();
		try {
			st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			rs = st.executeQuery(sqlVal);
		} catch (SQLException ex) {
			ex.printStackTrace();
		}
		return rs;
	}

	//关闭连接
	public void Dispose() {
		try {
			rs.close();
			st.close();
			conn.close();
		} catch (SQLException ex) {
			ex.printStackTrace();
		
			
		}
	}
}