java实现的数据库管理类(mysql)_MySQL

WBOY
풀어 주다: 2016-06-01 12:58:35
원래의
1197명이 탐색했습니다.

在我们使用数据库的时候,总会要写一个DBManager类来进行总体的数据库管理,在这里我们就要实现一个数据库管理类,这个是一个比较小型的数据库管理类,大体上实现了增删改查,在后面我们就会扩建这个数据库管理类,实现各种连接,来进行数据库的管理,好了,下面我们来看一下我们的代码:

<code class="hljs java">import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBManager {

    /**
     * 该方法用户连接数据库
     * 
     * @return 返回Connection的一个实例
     */
    private Connection getConnection() {

        Connection con = null;

        try {
            Class.forName(StaticVar.DRIVER_NAME).newInstance();

            con = DriverManager.getConnection(StaticVar.DB_URL,
                    StaticVar.USER_NAME, StaticVar.DB_PASSWD);

        } catch (InstantiationException e) {
            return null;
        } catch (IllegalAccessException e) {
            return null;
        } catch (ClassNotFoundException e) {
            return null;
        } catch (SQLException e) {
            return null;
        }

        return con;
    }

    /**
     * 用于查询sql语句
     * 
     * @param sql
     *            sql语句
     * @return 返回ResultSet集合
     */
    public ResultSet select(String sql) {
        ResultSet res = null;

        Connection con = getConnection();

        Statement state = null;

        if (!(con == null)) {

            try {
                state = con.createStatement();
                res = state.executeQuery(sql);
            } catch (SQLException e) {
                return null;
            }

        }

        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
                return null;
            }
        }

        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                return null;
            }
        }

        return res;
    }

    /**
     * 向表中插入一个元素,返回插入后的元素的id
     * 
     * @param sql
     * @return
     */
    public int insert(String sql) {
        int iId = -1;

        Connection con = getConnection();

        Statement state = null;

        if (con != null) {
            try {
                state = con.createStatement();

                int res = state.executeUpdate(sql,
                        Statement.RETURN_GENERATED_KEYS);

                if (res != 0) {
                    ResultSet rs = state.getGeneratedKeys();
                    if (rs.next()) {
                        iId = rs.getInt(1);
                    }
                }
            } catch (SQLException e) {
                iId = -1;
            }

        }

        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
            }
        }

        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
            }
        }

        return iId;
    }

    /**
     * 修改表中的某个元素的数值
     * 
     * @param sql
     *            sql语句
     * @return 元素是否被成功修改
     */
    public boolean update(String sql) {
        boolean updated = false;

        Connection con = getConnection();
        Statement state = null;

        if (con != null) {
            try {
                state = con.createStatement();

                int res = state.executeUpdate(sql);

                if (res == 0) {
                    updated = false;
                } else {
                    updated = true;
                }
            } catch (SQLException e) {
                updated = false;
            }

        }

        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
            }
        }

        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
            }
        }

        return updated;
    }

    /**
     * 删除表中的某一个表项
     * 
     * @param sql
     *            sql语句
     * @return 返回是否删除成功
     */
    public boolean delete(String sql) {
        boolean deleted = false;

        Connection con = getConnection();

        Statement state = null;

        if (con != null) {
            try {
                state = con.createStatement();

                int res = state.executeUpdate(sql);

                if (res == 0) {
                    deleted = false;
                } else {
                    deleted = true;
                }

            } catch (SQLException e) {
                deleted = false;
            }

        }

        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
            }
        }

        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
            }
        }

        return deleted;
    }

}
</code>
로그인 후 복사

下面看一下其中用到的一个类StaticVar。

StaticVar.java

<code class="hljs java"><code class="hljs java">
public class StaticVar {

    public static final String DB_URL = "jdbc:mysql://localhost/db_test?useUnicode=true&characterEncoding=UTF-8";

    public static final String USER_NAME = "chen";
    public static final String DB_PASSWD = "******";
    public static final String DRIVER_NAME = "com.mysql.jdbc.Driver";



}
</code></code>
로그인 후 복사

<code class="hljs java">这样我们的一个小型的数据库管理类就实现了,至于后面的扩展,我们会在后面的博客中讲到。

관련 라벨:
원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿