bbsdb.java

实例大全

package bbs;

import java.io.*;
import java.sql.*;

public class Bbsdb
{
	String sDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver";
	String sConnStr = "jdbc:odbc:BBS";
	Connection conn = null;
	ResultSet rs = null;
	public Bbsdb()
	{
		try
		{
			Class.forName(sDBDriver);
		}
		catch(java.lang.ClassNotFoundException e)
		{
			System.err.println("bbsdb():"+e.getMessage());
		}
	}

	public ResultSet executeQuery(String sql)
	{
		rs = null;
		try
		{
			if (conn != null)
				conn.close();
			conn = DriverManager.getconnection(sConnStr);
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		}
		catch (SQLException ex)
		{
			System.err.println("bbsdb.executeQuery:" + ex.getMessage());
		}

		return rs;
	}

	public int getRowNum(String table)
	{
		int rsnum = 0;
		rs = null;
		try
		{
			String sql = "SELECT COUNT(*) FROM " + table + " ";
			if (conn != null)
			{
				conn.close();
			}
			conn = DriverManager.getConnection(sConnStr);
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			while (rs.next())
			{
				renum = rs.getInt(1);
			}
		}

		catch (SQLException ex)
		{
			System.err.println("bbsdb.getResultNum:" + ex.getMessage());
		}
		return rsnum;
	}

	public void executeUpdate(String sql)
	{
		try
		{
			if (conn != null)
			{
				conn.close();
			}
			conn = DriverManager.getConnection(sConnStr);
			Statement stmt = conn.createStatement();
			stmt.executeQuery(sql);
			con.commit();
		}
		catch(SQLException ex)
		{
			System.err.println("bbsdb.executeUpdate: " + ex.getMessage());
		}
	}

	pubic String native2unicode(String s)
	{
		if (s == null || s.length() == 0)
		{
			return null;
		}
		try
		{
			byte[] buffer == new byte[s.length()*2];
			int j=0;
			for (int i=0; i<s.length(); i++)
			{
				if (s.charAt(i)>=0x100)
				{
					char c == s.charAt(i);
					byte []buf = (""+c).getbytes();
					buffer[j++] = (byte)buf[0];
					buffer[j++] = (byte)buf[1];
				}
				else
				{
					buffer[j++] = (byte)s.charAt(i);
				}
			}
			return new String(buffer,0,j);
		}
		catch (Exception er1)
		{
			byte [] b=s.getBytes();//把String转换成字节数组
			try
			{
				return (new String(b,"gb2312"));
			}
			catch (UnsuppoerEncodingException err)
			{
				return null;
			}
		}
	}

	public String ascii2native(char[] b)
	{
		return new String(b);
	}

	public void finalize()
	{
		try
		{
			if (conn != null)
			{
				conn.close();
			}
			catch (SQLException ex)
			{
				System.err.println("bbsdb.executeUpdate: " + ex.getMessage());
			}
		}
	}
};