connectdb.java

文件的上传和下载的实现,用JAva编写,非常简单

package edu.whut.cwts.hc;

import java.sql.*;
import java.util.Hashtable;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;

import edu.whut.cwts.datasource.DBConnect;

public class ConnectDB {
	DataSource ds = null;

	Context ctx = null;

	Connection conn = null;

	ResultSet rs = null;

	Statement statement = null;

	/**
	 * @return 返回 conn。
	 */
	public Connection getConn() {
		return conn;
	}

	/**
	 * @param conn
	 *            要设置的 conn。
	 */
	public void setConn(Connection conn) {
		this.conn = conn;
	}

	/**
	 * @return 返回 rs。
	 */
	public ResultSet getRs() {
		return rs;
	}

	/**
	 * @param rs
	 *            要设置的 rs。
	 */
	public void setRs(ResultSet rs) {
		this.rs = rs;
	}

	/**
	 * @return 返回 stmt。
	 */
	public Statement getStmt() {
		return statement;
	}

	/**
	 * @param stmt
	 *            要设置的 stmt。
	 */
	public void setStmt(Statement statement) {
		this.statement = statement;
	}

	// 构造函数
	public ConnectDB(){

		Hashtable ht = new Hashtable();
		ht.put(Context.INITIAL_CONTEXT_FACTORY,
				"weblogic.jndi.WLInitialContextFactory");
		ht.put(Context.PROVIDER_URL, "t3://localhost:7001");
		try {
			ctx = new InitialContext(ht);
			ds = (DataSource) ctx.lookup("hyfdbjndi");
			conn = ds.getConnection("weblogic", "12341234");// 此处是WebLogic8.1的域用户和密码
			statement = conn.createStatement();
		} catch (Exception e) {
			System.out.println(e.getMessage());
		}
	}

	public ResultSet executeQuery(String sql) {
		ResultSet rs = null;
		try {
			rs = statement.executeQuery(sql);
		} catch (SQLException e) {
			System.err.println("executeQuery():" + e.getMessage());
		}
		return rs;
	}

	/**
	 * @param String
	 *            sql
	 * @return int 如果i=1，则操作成功
	 * 
	 */
	public int executeUpdate(String sql) {
		int i = 0;
		try {
			i = statement.executeUpdate(sql);
		} catch (SQLException e) {
			System.err.println("executeUpdate():" + e.getMessage());
		}
		return i;
	}

	public void close() {
		try {
			statement.close();
			conn.close();
		} catch (SQLException e) {
			System.err.println("close()" + e.getMessage());
		}

	}

	public static void main(String[] args) {

		String sql = "select * from zdxxb where zddm like'%0000' ";

		DBConnect dbconn = new DBConnect();

		try {

			ResultSet rs = dbconn.executeQuery(sql);
			// i= dbconn.executeUpdate(sql);
			while (rs.next()) {
				System.out.println(rs.getString(1) + "    " + rs.getString(2)
						+ "   ");

			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		dbconn.close();

		// System.out.println(i);
		// System.out.println(rs2);
		// if(i==1&&rs2==false){result=true;}
		// System.out.println(result);
	}

}