people_conn.java~19~

嘿嘿 很好的一个代码 很适合初学者开发 看看把

package Conn;

import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.DriverManager;
import java.sql.*;
import java.util.*;
import Bean.PeopleBean;

/**
 *
 * <p>Title:连接数据库 </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */

public class People_Conn {
    PeopleBean objpeoplebean = null;

    Connection con;
    Statement st;
    ResultSet rs;

    String url;
    String serverName;
    String portNumber;
    String databaseName;
    String userName;
    String pwd;
    String sql;

    /**
     * 初始化连接数据库
     */
    public People_Conn() {
        con = this.getConnection();
        try {
            st = con.createStatement();
        } catch (SQLException ex) {
            System.out.println("失败！！");
            ex.printStackTrace();
        }
    }

    /**
     * 添加数据
     * @param name String
     * @param sex String
     * @param add String
     * @param email String
     * @param likes String
     * @param dept String
     * @param jieshao String
     * @return boolean
     */
    public boolean addPeopleInfo(String name, String sex, String add,
                                 String email, String likes, String dept,
                                 String jieshao) {
        String sql =
                "insert into peoples(peopleName,sex,address,email,likes,dept,jieshao)values('" +
                name + "','" + sex + "','" + add + "','" + email + "','" +
                likes +
                "','" + dept + "','" + jieshao + "')";
        System.out.println("sql: " + sql);
        try {
            st.executeUpdate(sql);
            System.out.println("添加成功！！");
            return true;
        } catch (Exception ex) {
            System.out.println("添加失败！！");
            ex.printStackTrace();
        }
        return false;
    }

    /**
     * 根据编号删除数据并返回true或者false
     * @param id int
     * @return boolean
     */
    public boolean deletePeopleInfo(int id) {
        String sql = "delete peoples where peopleId='" + id + "'";
        try {
            st.executeUpdate(sql);
            return true;
        } catch (Exception ex) {
            System.out.println("删除失败！！");
            ex.printStackTrace();
        }
        return false;
    }

    /**
     * 查询全部数据并返回List
     * @return List
     */
    public List SelectUserInfo() {
        List objlist = new ArrayList();
        String sql = "select *from peoples";
        try {
            rs = st.executeQuery(sql);
            while (rs.next()) {
                objpeoplebean = new PeopleBean();
                objpeoplebean.setId(rs.getInt(1));
                objpeoplebean.setName(rs.getString(2));
                objpeoplebean.setAdd(rs.getString(3));
                objpeoplebean.setEmail(rs.getString(4));
                objlist.add(objpeoplebean);
            }
            System.out.println("查询成功！！");
            return objlist;
        } catch (Exception ex) {
            System.out.println("查询失败！！");
            ex.printStackTrace();
        }
        return null;
    }

    /**
     * 查询全部数据并返回List
     * @return List
     */
    public List selectUser(String id) {
        List objlist = new ArrayList();
        String sql = "select * from peoples where peopleId=" +id;
        System.out.println("sql==="+sql);
        PeopleBean objpeoplebean=null;
        try {
            rs = st.executeQuery(sql);
            if (rs.next()) {
                objpeoplebean = new PeopleBean();
                objpeoplebean.setId(rs.getInt(1));
                objpeoplebean.setName(rs.getString(2));
                objpeoplebean.setSex(rs.getString(3));
                objpeoplebean.setAdd(rs.getString(4));
                objpeoplebean.setEmail(rs.getString(5));
                objpeoplebean.setLikes(rs.getString(6));
                objpeoplebean.setDept(rs.getString(7));
                objpeoplebean.setJieshao(rs.getString(8));
            }
            objlist.add(objpeoplebean);
            System.out.println("根据编号查询用户成功！！");
            return objlist;
        } catch (Exception ex) {
            System.out.println("查询失败！！");
            ex.printStackTrace();
        }
        return null;
    }

    /**
     * 根据编号更新数据
     * @param id int
     * @param name String
     * @param add String
     * @param email String
     */
    public boolean updatePeopleInfo(int id, String name, String sex, String add,
                                    String email, String likes, String dept,
                                    String jieshao) {
        String sql = "update peoples set peopleName='" + name + "','" + sex +
                     "',address='" + add + "',email='" + email + "',likes='" +
                     likes + "',dept='" + dept + "',jieshao='" + jieshao +
                     "' where peopleId=" + id + "";
        System.out.println("sql:"+sql);
        try {
            st.executeUpdate(sql);
            System.out.println("修改成功！！");
            return true;
        } catch (Exception ex) {
            System.out.println("更新失败！！");
            ex.printStackTrace();
        }
        return false;
    }


    /**
     * 获取连接路径
     * @return String
     */
    private String getConnectionUrl() {
        url = "jdbc:microsoft:sqlserver://";
        serverName = "localhost";
        portNumber = "1433";
        databaseName = "PeopleInfo";
        userName = "sa";
        pwd = "sa";
        return url + serverName + ":" + portNumber + ";databaseName=" +
                databaseName + ";";
    }

    /**
     * 连接数据库
     * @return Connection
     */
    private java.sql.Connection getConnection() {
        try {
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
            con = java.sql.DriverManager.getConnection(getConnectionUrl(),
                    userName, pwd);
            if (con != null) {
                System.out.println("连接成功！！");
            } else {
                System.out.println("连接失败！！");
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return con;
    }
}