怎么讀取數據庫中數據

1.要先了解是用MVC的思想來實現，MVC是由模型層(Model),視圖層(View)和控制器層(Controller)這三個相互獨立的層面所組成的。

2.第二步是很重要的，你要有MYSQL，並在其中創建表。

3.在MyEclipse中建立一個項目並給項目取一個名字，在此我建立的名字為userManager。

4.現在來分析M層需要什么，然而M需要建立實體類,dao層和DBHelper類(DBHelper是一個很好用的類,將要用的封裝起來)

4.1 建立實體類(User)，需要根據數據庫中定義的內容來制定，例如

package entity;

public class User {
    private String userID;//數據成員(字段)
    private String userName;
    private String password;
    public String getUserID() {
        return userID;
    }
    public void setUserID(String userID) {
        this.userID = userID;
    }
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    

}

在以上代碼中定義了3個數據成員，分別是userID，userName，password;它們都定義為私有的。

4.2 建立dao層

package dao;

import java.util.*;
import java.sql.*;
import entity.*;
import DBHelper.DBHelper;

public class Userdao {
    public List getAllUser()
    {
        try
        {
        String SQL="SELECT* FROM user";
        ResultSet rs=DBHelper.getResultSet(SQL);
        List users=new ArrayList();
        while(rs.next())
        {
            User u=new User();
            u.setUserID(rs.getString("userID"));
            u.setUserName(rs.getString("userName"));
            u.setPassword(rs.getString("password"));
            users.add(u); 
        }
        return users;
    }
        catch(Exception ex){
            ex.printStackTrace();
            return null;
            }
        
}
}

在以上代碼中體現的是要查詢所有的用戶數據

List是列表的意思,List getAllUser是列出所有的數據

try是拋出異常

String SQL="SELECT * FROM user"是指查詢數據庫中user表

ResultSet rs=DBHelper.getResultSet(SQL);是指結果等於SQL中的數據結果集

List users=new ArrayList();是指輸出用戶列表

然后用循環語句來遍歷數據

while(rs.next())
        {
            User u=new User();
            u.setUserID(rs.getString("userID"));
            u.setUserName(rs.getString("userName"));
            u.setPassword(rs.getString("password"));
            users.add(u); 
        }

返回值為 users

最后寫一個捕獲異常的語句，返回值為空

4.3 DBHelper

package DBHelper;

import java.io.Console;
import java.sql.*;
import java.util.Enumeration;
//import java.util.logging.*;
//import javax.swing.table.*;

/**
 *  SQL 基本操作
 * 通過它,可以很輕松的使用 JDBC 來操縱數據庫
 * @author Null
 */
public class DBHelper
{

    /**
     * 驅動
     */
    //public static String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
    public static String driver = "com.mysql.jdbc.Driver";
    /**
     * 連接字符串
     */
    //public static String url = "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=st";
    public static String url = "jdbc:mysql://127.0.0.1:3306/test";
    /**
     * 用戶名
     */
    public static String user = "root";
    /**
     * 密碼
     */
    public static String password = "root";

    /**
     * 不允許實例化該類
     */
    private DBHelper()
    {
    }

    /**
     * 獲取一個數據庫連接
     * 通過設置類的  driver / url / user / password 這四個靜態變量來 設置數據庫連接屬性
     * @return 數據庫連接
     */
    public static Connection getConnection()
    {
        try
        {
            //獲取驅動
            Class.forName(driver);
        } catch (ClassNotFoundException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
        }

        try
        {
            return DriverManager.getConnection(url, user, password);
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            return null;
        }
    }

    /**
     * 獲取一個 Statement
     * 該 Statement 已經設置數據集 可以滾動,可以更新
     * @return 如果獲取失敗將返回 null,調用時記得檢查返回值
     */
    public static Statement getStatement()
    {
        Connection conn = getConnection();
        if (conn == null)
        {
            return null;
        }
        try
        {
            return conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
        // 鐠佸墽鐤嗛弫鐗堝祦闂嗗棗褰叉禒銉︾泊閸旓拷閸欘垯浜掗弴瀛樻煀
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            close(conn);
        }
        return null;
    }

    /**
     * 獲取一個 Statement
     * 該 Statement 已經設置數據集 可以滾動,可以更新
     * @param conn 數據庫連接
     * @return 如果獲取失敗將返回 null,調用時記得檢查返回值
     */
    public static Statement getStatement(Connection conn)
    {
        if (conn == null)
        {
            return null;
        }
        try
        {

            return conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            // 設置數據集可以滾動,可以更新
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            return null;
        }
    }

    /**
     * 獲取一個帶參數的 PreparedStatement
     * 該 PreparedStatement 已經設置數據集 可以滾動,可以更新
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return 如果獲取失敗將返回 null,調用時記得檢查返回值
     */
    public static PreparedStatement getPreparedStatement(String cmdText, Object[] cmdParams)
    {
        Connection conn = getConnection();
        if (conn == null)
        {
            return null;
        }

        PreparedStatement pstmt = null;
        try
        {
            
            pstmt = conn.prepareStatement(cmdText, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            int i = 1;
            for (Object item : cmdParams) //java foreach遍歷集合,要求集合類實現Enumeration接口
            {
                pstmt.setObject(i, item);
                i++;
            }
        } catch (SQLException e)
        {
            e.printStackTrace();
            close(conn);
        }
        return pstmt;
    }

    /**
     *  獲取一個帶參數的 PreparedStatement
     * 該 PreparedStatement 已經設置數據集 可以滾動,可以更新
     * @param conn 數據庫連接
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return 如果獲取失敗將返回 null,調用時記得檢查返回值
     */
    public static PreparedStatement getPreparedStatement(Connection conn, String cmdText, Object[] cmdParams)
    {
        if (conn == null)
        {
            return null;
        }

        PreparedStatement pstmt = null;
        try
        {
            pstmt = conn.prepareStatement(cmdText, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            int i = 1;
            for (Object item : cmdParams)
            {
                pstmt.setObject(i, item);
                i++;
            }
        } catch (SQLException ex)
        {
            System.out.println(ex.getMessage());
            //ex.printStackTrace();
            close(pstmt);
        }
        return pstmt;
    }

    /**
     * 執行 SQL 語句,返回結果為整型
     * 主要用於執行非查詢語句
     * @param cmdText SQL 語句
     * @return 非負數:正常執行; -1:執行錯誤; -2:連接錯誤
     */
    public static int ExecSql(String cmdText)
    {
        Statement stmt = getStatement();
        if (stmt == null)
        {
            return -2;
        }
        int i;
        try
        {
            i = stmt.executeUpdate(cmdText);
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null,ex);
            System.out.println(ex.getMessage());
            i = -1;
        }
        closeConnection(stmt);
        return i;
    }

    /**
     * 執行 SQL 語句,返回結果為整型
     * 主要用於執行非查詢語句
     * @param cmdText SQL 語句
     * @return 非負數:正常執行; -1:執行錯誤; -2:連接錯誤
     */
    public static int ExecSql(Connection conn, String cmdText)
    {
        Statement stmt = getStatement(conn);
        if (stmt == null)
        {
            return -2;
        }
        int i;
        try
        {
            i = stmt.executeUpdate(cmdText);

        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
           
            i = -1;
        }
        close(stmt);
        return i;
    }

    /**
     * 執行 SQL 語句,返回結果為整型
     * 主要用於執行非查詢語句
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return 非負數:正常執行; -1:執行錯誤; -2:連接錯誤
     */
    //非常好用
    public static int ExecSql(String cmdText, Object[] cmdParams)
    {
        PreparedStatement pstmt = getPreparedStatement(cmdText, cmdParams);
        if (pstmt == null)
        {
            return -2;
        }
        int i;
        try
        {
            i = pstmt.executeUpdate();
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
           i = -1;
        }
        closeConnection(pstmt);
        return i;
    }

    /**
     * 執行 SQL 語句,返回結果為整型
     * 主要用於執行非查詢語句
     * @param conn 數據庫連接
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return 非負數:正常執行; -1:執行錯誤; -2:連接錯誤
     */
    public static int ExecSql(Connection conn, String cmdText, Object[] cmdParams)
    {
        PreparedStatement pstmt = getPreparedStatement(conn, cmdText, cmdParams);
        if (pstmt == null)
        {
            return -2;
        }
        int i;
        try
        {
            i = pstmt.executeUpdate();

        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            i = -1;
        }
        close(pstmt);
        return i;
    }

    /**
     * 返回結果集的第一行的一列的值,其他忽略
     * @param cmdText SQL 語句
     * @return
     */
    public static Object ExecScalar(String cmdText)
    {
        ResultSet rs = getResultSet(cmdText);
        Object obj = getScalar(rs);
        closeConnection(rs);
        return obj;
    }

    /**
     * 返回結果集的第一行的一列的值,其他忽略
     * @param conn 數據庫連接
     * @param cmdText SQL 語句
     * @return
     */
    public static Object ExecScalar(Connection conn, String cmdText)
    {
        ResultSet rs = getResultSet(conn, cmdText);
        Object obj = getScalar(rs);
        closeEx(rs);
        return obj;
    }

    /**
     * 返回結果集的第一行的一列的值,其他忽略
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return
     */
    public static Object ExecScalar(String cmdText, Object[] cmdParams)
    {
        ResultSet rs = getResultSet(cmdText, cmdParams);
        Object obj = getScalar(rs);
        closeConnection(rs);
        return obj;
    }

    /**
     * 返回結果集的第一行的一列的值,其他忽略
     * @param conn 數據庫連接
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return
     */
    public static Object ExecScalar(Connection conn, String cmdText, Object[] cmdParams)
    {
        ResultSet rs = getResultSet(conn, cmdText, cmdParams);
        Object obj = getScalar(rs);
        closeEx(rs);
        return obj;
    }

    /**
     * 返回一個 ResultSet
     * @param cmdText SQL 語句
     * @return
     */
    public static ResultSet getResultSet(String cmdText)
    {
        Statement stmt = getStatement();
        if (stmt == null)
        {
            return null;
        }
        try
        {
            return stmt.executeQuery(cmdText);
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
           closeConnection(stmt);
        }
        return null;
    }

    /**
     * 返回一個 ResultSet
     * @param conn
     * @param cmdText SQL 語句
     * @return
     */
    public static ResultSet getResultSet(Connection conn, String cmdText)
    {
        Statement stmt = getStatement(conn);
        if (stmt == null)
        {
            return null;
        }
        try
        {
            return stmt.executeQuery(cmdText);
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            close(stmt);
        }
        return null;
    }

    /**
     * 返回一個 ResultSet
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return
     */
    public static ResultSet getResultSet(String cmdText, Object[] cmdParams)
    {
        PreparedStatement pstmt = getPreparedStatement(cmdText, cmdParams);
        if (pstmt == null)
        {
            return null;
        }
        try
        {
            return pstmt.executeQuery();
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            closeConnection(pstmt);
        }
        return null;
    }

    /**
     * 返回一個 ResultSet
     * @param conn 數據庫連接
     * @param cmdText 需要 ? 參數的 SQL 語句
     * @param cmdParams SQL 語句的參數表
     * @return
     */
    public static ResultSet getResultSet(Connection conn, String cmdText, Object[] cmdParams)
    {
        PreparedStatement pstmt = getPreparedStatement(conn, cmdText, cmdParams);
        if (pstmt == null)
        {
            return null;
        }
        try
        {
            return pstmt.executeQuery();
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
            close(pstmt);
        }
        return null;
    }

    public static Object getScalar(ResultSet rs)
    {
        if (rs == null)
        {
            return null;
        }
        Object obj = null;
        try
        {
            if (rs.next())
            {
                obj = rs.getObject(1);
            }
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
        }
        return obj;
    }
 
    private static void close(Object obj)
    {
        if (obj == null)
        {
            return;
        }
        try
        {
            if (obj instanceof Statement)
            {
                ((Statement) obj).close();
            } else if (obj instanceof PreparedStatement)
            {
                ((PreparedStatement) obj).close();
            } else if (obj instanceof ResultSet)
            {
                ((ResultSet) obj).close();
            } else if (obj instanceof Connection)
            {
                ((Connection) obj).close();
            }
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
       }
    }

    private static void closeEx(Object obj)
    {
        if (obj == null)
        {
            return;
        }

        try
        {
            if (obj instanceof Statement)
            {
                ((Statement) obj).close();
            } else if (obj instanceof PreparedStatement)
            {
                ((PreparedStatement) obj).close();
            } else if (obj instanceof ResultSet)
            {
                ((ResultSet) obj).getStatement().close();
            } else if (obj instanceof Connection)
            {
                ((Connection) obj).close();
            }
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
        }

    }

    private static void closeConnection(Object obj)
    {
        if (obj == null)
        {
            return;
        }
        try
        {
            if (obj instanceof Statement)
            {
                ((Statement) obj).getConnection().close();
            } else if (obj instanceof PreparedStatement)
            {
                ((PreparedStatement) obj).getConnection().close();
            } else if (obj instanceof ResultSet)
            {
                ((ResultSet) obj).getStatement().getConnection().close();
            } else if (obj instanceof Connection)
            {
                ((Connection) obj).close();
            }
        } catch (SQLException ex)
        {
            //Logger.getLogger(DBHelper.class.getName()).log(Level.SEVERE, null, ex);
            System.out.println(ex.getMessage());
       }
    }
}

5.在C層控制器層(Controller)中建立servlet類

public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
            doPost(request, response);
    }

    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        Userdao dao=new Userdao();
        List users=dao.getAllUser();
        request.getSession().setAttribute("users", users);
        response.sendRedirect("../user.jsp");
        
    }

在servlet中主要寫執行語句

List users=dao.getAllUser();

顯示所有用戶列表

request.getSession().setAttribute("users", users);

請求會話的屬性

response.sendRedirect("../user.jsp");

跳轉的頁面路徑

6.記得要加入SQL的驅動

7.在V層視圖層(View)中寫入一個jsp,取名為user,在里面寫入動態內容

<body>
    <% 
        List<User> users =(List<User>)session.getAttribute("users");
        out.print("<table border=1>");
        out.print("<tr><td>用戶ID</td><td>用戶名</td><td>密碼</td></tr>");
        for(User u : users)
        {
            out.print("<tr>");
            out.print("<td>"+u.getUserID()+"</td>");
            out.print("<td>"+u.getUserName()+"</td>");
            out.print("<td>"+u.getPassword()+"</td>");
            out.print("</tr>");
        }
        out.print("</table>");
    %>
  </body>

8.最后就大功告成了

在這里顯示中有？？，是因為有亂碼問題，還在解決中