一个applet servlet之间通过序列化对象通讯的例子

源代码在线查看: dbconnection.java~13~

软件大小: 838 K
上传用户: wangshengzaishi
关键词: servlet applet 序列 对象
下载地址: 免注册下载 普通下载 VIP

相关代码

				package espc;								import java.io.*;				import java.sql.*;				import java.util.Properties;								public class DbConnection				{								    Connection conn=null;				    Statement stmt=null;				    ResultSet rset=null;				    //构造方法				    public DbConnection()				    {								    }								    public boolean openConnection()				    {				    //-----------------------------------------------------------------				    //装载数据库的Property文件:其中包括数据库驱动,数据库URL,即用户ID和密码				    //-----------------------------------------------------------------				      Properties prop = new Properties();				        try				        {				            InputStream is = getClass().getResourceAsStream("Db.properties");				            prop.load(is);				            if(is != null)				             is.close();				        }				        catch(IOException e)				        {				            System.out.println("[DbConnection]打开文件时出现错误!");				        }				        //-----------------------------------------------------------				        //从property文件中读出数据库Property				        //-----------------------------------------------------------				        String jdbc = prop.getProperty("drivers");				        String url = prop.getProperty("url");				        String user = prop.getProperty("user");				        String password = prop.getProperty("password");				        //-----------------------------------------------------------				        //将输入的property输出到Debugging				        //-----------------------------------------------------------				        System.out.println(String.valueOf(String.valueOf((new StringBuffer("jdbc=[")).append(jdbc).append("]"))));				        System.out.println(String.valueOf(String.valueOf((new StringBuffer("url=[")).append(url).append("]"))));				        System.out.println(String.valueOf(String.valueOf((new StringBuffer("user=[")).append(user).append("]"))));				        System.out.println(String.valueOf(String.valueOf((new StringBuffer("password=[")).append(password).append("]"))));				        //-----------------------------------------------------------				        //加载jdbc驱动				        //-----------------------------------------------------------				        try				        {				            Class.forName(jdbc);				            System.out.println("驱动程序加载成功!");				        }				        catch(ClassNotFoundException e)				        {				            System.out.println("JDBC登陆过程中出现错误".concat(String.valueOf(String.valueOf(e.getMessage()))));				            boolean flag = false;				            return flag;				        }				        //-----------------------------------------------------------				        //打开数据库connection				        //-----------------------------------------------------------				        try				        {				            conn = DriverManager.getConnection(url, user, password);				            System.out.println("数据库连接成功!!");				        }				        catch(SQLException e)				        {				            System.out.println("数据库连接过程中出现错误".concat(String.valueOf(String.valueOf(e.getMessage()))));				            boolean flag1 = false;				            return flag1;				        }				        return true;				    }								    /****************************************************************************				     *方法名称:executeQuery				     *参数:query(SQL查询语句)				     *返回值类型:java.sql.ResultSet				     *说明:查询数据库的方法(SELECT)				    ****************************************************************************/				    public ResultSet executeQuery(String query)				        throws SQLException				    {				        stmt = conn.createStatement();				        rset = stmt.executeQuery(query);				        return rset;				    }				    /****************************************************************************				    *方法名称:executeUpdate				    *参数:query(SQL查询语句)				    *返回值类型:void				    *说明:查询数据库的方法(UPDATE,DELETE,INSERT)				    ****************************************************************************/				    public void executeUpdate(String query)				        throws SQLException				    {				        stmt = conn.createStatement();				        stmt.executeUpdate(query);				        if(stmt != null)				            stmt.close();				    }				    /****************************************************************************				    *方法名称:close				    *参数:无				    *返回值类型:void				    *说明:返回数据库链接的相关资料				    ****************************************************************************/				    public void close()				        throws SQLException				    {				        if(conn != null)				            conn.close();				        if(rset != null)				            rset.close();				        if(stmt != null)				            stmt.close();				    }				    /****************************************************************************				    *方法名称:finalize				    *参数:无				    *返回值类型:void				    *说明:从服务器回收资源				    ****************************************************************************/				    protected void finalize()				        throws Throwable				    {				        close();				    }				}			

相关资源