db.java

实现一个J2EE上传功能完整的源代码

package com.dao;

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

public class DB {

	public Connection getCon() {
		try {
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
		} catch (ClassNotFoundException e) {
			
			e.printStackTrace();
		}
		Connection con = null;
		try {
			con = DriverManager
					.getConnection(
							"jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=hello",
							"sa", "liujk");
		} catch (SQLException e) {
			
			e.printStackTrace();
		}
		return con;
	}

	public Statement getStm() {
		Statement stm = null;
		try {
			stm = getCon().createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return stm;
	}

	public ResultSet seach(String sql) {
		ResultSet rs = null;
		try {
			rs = getStm().executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}

	public int add(String sql) {
		int i = -1;
		try {
			i = getStm().executeUpdate(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return i;
	}
}