ajax与jsp开发的留言本-数据库操作类

发布时间:2020-05-30编辑:脚本学堂
一个留言板留言提交与读取的简单实例,不包括回复、编辑与删除等功能。
本实例旨在用一个简单的例子展示如何在java web开发中用javascript开发Ajax应用。

四、DataSql  数据库操作类

package edu.scnu.cn.common;
import java.sql.*;
/** *//**
 *
 * @author li
 *
 *数据库操作类
 */
public class DataSql ...{
    /** *//**
     *
     * @return
     * @throws InstantiationException
     * @throws IllegalAccessException
     * @throws ClassNotFoundException
     *
     * 直接连接到数据库,数据库指定为crjy
     */
   
    public  Connection getConn() throws InstantiationException, IllegalAccessException, ClassNotFoundException
    ...{
        //数据库用户名
        String userName="root";
        //密码
        String userPasswd="admin222";
        //数据库名
        String dbName="crjy";       
        //联结字符串
        String url="jdbc:mysql://localhost:3306/"+dbName+"?useUnicode=true&characterEncoding=GB2312&user="+userName+"&password="+userPasswd;
        Class.forName("com.mysql.jdbc.Driver").newInstance();
        Connection conn=null;   
        try
        ...{
            conn = DriverManager.getConnection(url);
        }
        catch (SQLException e)
        ...{
            e.printStackTrace();
        }   
        return conn;       
    }
   
    /** *//**
     *
     * @param conn        到数据库的连接
     * @param sql        sql串
     * @return
     *
     * 得到数据集
     *
     */
    public ResultSet getRs(Connection conn,String sql)
    ...{
        Statement statement=null;
        ResultSet rs=null;
        try ...{
            statement = conn.createStatement();
            rs = statement.executeQuery(sql);
        } catch (SQLException e) ...{
            // TODO 自动生成 catch 块
            e.printStackTrace();
        }
   
        return rs;       
    }
   
    /** *//**
     *
     * @param conn        到数据库的连接  
     * @param sql        sql串
     * @return
     *
     * 执行删除,更新等操作
     */
    public int execute(Connection conn,String sql)
    ...{
        Statement statement=null;
        int i=0;
        try ...{
            statement = conn.createStatement();
            i= statement.executeUpdate(sql);
        } catch (SQLException e) ...{
            // TODO 自动生成 catch 块
            e.printStackTrace();
        }
   
        return i;       
    }
}