JDBC编程——建立连接，并简单操作

JDBC:Java DataBase Connectivity standard
1.首先下载连接MySQL的驱动
　　

mysql-connector-java-5.1.24-bin.jar

2.创建数据库的用户名和密码文件，易于统一管理

day1/xxx.properties

user=root
2 password = root

3.获得propertiese对象

// 获取数据库的用户名和密码
Properties prop = new Properties();
prop.load(Inserte.class
         .getResourceAsStream("/day1/database.properties"));

4.添加驱动，连接数据库

 Class.forName("com.mysql.jdbc.Driver");
 // 建立连接
 conn = DriverManager.getConnection(
         "jdbc:mysql://localhost:3306/com.xhm.sql", prop);

5.获得数据库操作对象

// 获取执行SQL对象
stmt = conn.createStatement();

6.执行sql语句，进行增删检查

6.1插入SQL语句格式如下：

INSERT [INTO] tablename VALUES (expression[,...n]);
其中INTO是可选的，tablename是表明称，在VALUES后的括号放入插入的数据，和建表的要类型要对应，并按顺序插入如：
inser into student values(1,'Lee',30);

6.2修改操作SQL语句格式如下：

UPDATE tablename SET columnname = {expression}[,...n] WHERE<search_condition>
使用该语句为修改名称为columnname列的值，expression为指定的值，WHERE为修改的对象的条件，如果没有会对所有的对象经行修改。
如下：
UPDATE tablename SET age = 34 WHERE name = 'Tom';

6.3删除操作SQL语句格式如下：

DELETE [FROM] tablename WHERE search_condition
和修改一样需要给出条件，否则将全部删除了

6.4查询操作SQL语句格式如下：

SELECT select_list FROM tablename[WHERE search_condition][GROUP BY group_by_expression][HAVING search_condition][ORDER BY order_expression[ASC|DESC]]
其中的“select_list”表示要查询哪些列，如果使用了*表示查询所有列，WHERE后面是查询条件。返回的是一个ResultSet对象，使用.next（）来遍历。rs对象初始化时在第一个数据前即：-1.

// 执行sql语句返回的是执行的次数，用于添加，更新，删除
row = stmt.executeUpdate(sql);
//执行sql查询语句，用于查询
 resultset = stmt.executeQuery(sql);

7.使用后，需要关闭数据库的连接和数据库操作对象的连接

       finally {
            try {
                if (stmt != null) {
                    stmt.close();
                }
            } catch (Exception e2) {
                // TODO: handle exception
                System.out.println("关闭Statement对象出现的问题！");
            } finally {
                try {
                    if (conn != null) {
                        conn.close();
                    }
                } catch (Exception e3) {
                    // TODO: handle exception
                    System.out.println("关闭数据库连接时出现问题！");
                }
            }

完整代码如下：

package day1;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class Inserte {
    public int Insert() {
        int row = 0;
        Connection conn = null;
        Statement stmt = null;
        // 加载驱动
        try {
            /**
             * 建议使用这种方法来加载用户名和密码，易于修改和管理 建立一个.properties文件，然后填入键值对 user = root
             * password = root
             */
            // 获取数据库的用户名和密码
            Properties prop = new Properties();
            prop.load(Inserte.class
                    .getResourceAsStream("/day1/database.properties"));
            Class.forName("com.mysql.jdbc.Driver");
            // 建立连接
            conn = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/com.xhm.sql", prop);
            // 获取执行SQL对象
            stmt = conn.createStatement();
            // 定义插入SQL语句
            String sql = "insert into student values(6,'Perike',50)";
            // 执行sql语句返回的是执行的次数
            row = stmt.executeUpdate(sql);
            //执行sql查询语句
            //stmt.executeQuery(sql);
            //System.out.println("row=" + row);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            try {
                if (stmt != null) {
                    stmt.close();
                }
            } catch (Exception e2) {
                // TODO: handle exception
                System.out.println("关闭Statement对象出现的问题！");
            } finally {
                try {
                    if (conn != null) {
                        conn.close();
                    }
                } catch (Exception e3) {
                    // TODO: handle exception
                    System.out.println("关闭数据库连接时出现问题！");
                }
            }
        }
        return row;
    }
}

7.预编译语句，防止注入攻击

　　　7.1SQL注入攻击：　

    String name = "Tom";
    String sql = "select * from student where name = ' "+name+" ' ";
    实际SQL语句为：select * from student where name = 'Tom'
    //当改变name内容时，
    String name = "Tom 'or' a'='a";
    String sql = "select * from student where name = "+name+"";
    实际SQL语句为：select *from student where name = 'Tom' or 'a' = 'a'即select * from student

　　7.2使用PerpareStatement

    /**
     * PrepareStatement创建SQL语句时候就会编译，
     * 存储在PrepareStatement对象中，所以当需要多次
     * 执行同一SQL语句的时候，使用他可以大大增加效率。
     */
    String sql = "select * from student where name = ?";
    PreparedStatement pstmt = conn.prepareStatement(sql);
    //设置sql中的问号，从1开始计算
    pstmt.setString(1,"Tom");
    ResultSet rs = pstmt.execute(sql);

工具类：

/*************************
 *@author 徐宏明    E-Mail：android_xhm.126.com
 *                                        QQ:294985925
 *@version 创建时间            ：2013-5-19 下午11:54:34
 *
 *@see
 *************************/
package day1;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * JDBC工具类，连接数据库
 * 
 * @author 宏明
 * 
 */
public class DBConnection {
    // 驱动类名
    private static final String DBDRIVER = "com.mysql.jdbc.Driver";
    // 连接URL
    private static final String DBURL = "jdbc:mysql://localhost:3306/javaweb";
    // 数据库的用户名
    private static final String DBUSER = "root";
    // 数据库的密码
    private static final String DBPASSWORD = "root";
    // 静态块，用来加载驱动
    static {
        try {
            Class.forName(DBDRIVER);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("加载驱动失败！！！");
        }
    }

    /**
     * 建立获取连接的方法
     * 
     * @return 数据库连接对象
     */
    public static Connection getConnection() {
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("发生连接异常！！！");
        }
        return conn;
    }

    /**
     * 关闭数据库连接
     * 
     * @param conn
     *            数据库连接
     */
    public static void closeConn(Connection conn) {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("关闭数据库发生异常！！！");
            }
        }
    }

    /**
     * 关闭数据库操作对象
     * 
     * @param stmt
     *            数据库操作对象
     */
    public static void closeStmt(Statement stmt) {
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("关闭数据库操作对象发生异常！！！");
            }
        }
    }

    /**
     * 关闭结果集方法
     * 
     * @param rs
     *            结果集
     */
    public static void closeRs(ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("关闭结果集发生异常！！！");
            }
        }
    }
}