Java连接数据库 --- 主推预编译Statement

准备工作   1.创建数据库



                 2.导入jar包    我使用的是  mysql-connector-java-5.1.8-bin.jar

简单的插入数据

方法一：预编译Statement

try {
	/**
	 * 通过Class.forName 初始化驱动类com.mysql.jdbc.Driver
	*/
    Class.forName("com.mysql.jdbc.Driver");
	/*
	 * 连接数据库  信息，用户，密码 
	*/
	Connection c = DriverManager.getConnection("jdbc:mysql://localhost:3306/login?characterEncoding=UTF-8","root","123456");
	System.out.println("数据库连接成功"+c);
	/**
	* 方法1:预编译Statement
	* PreparedStatement 执行10次，只需要1次把SQL语句传输到数据库端
    * 数据库对带?的SQL进行预编译
    * 每次执行，只需要传输参数到数据库端
    * 1. 网络传输量比Statement更小
    * 2. 数据库不需要再进行编译，响应更快
    * 3. 杜绝注入式攻击
	*/
	String sql = "insert into user values(null,?,?)";
	PreparedStatement pStatement = c.prepareStatement(sql);
    //设置数据
    //传入多组数据用for循环
	pStatement.setString(1, "zhansan");
	pStatement.setString(2, "zhansan123456");
    //执行
	pStatement.execute();
}catch (SQLException e) {
    // TODO Auto-generated catch block
	e.printStackTrace();
}catch (ClassNotFoundException e) {
	e.printStackTrace();
} 


方法二：statement

try {
	/**
	* 通过Class.forName 初始化驱动类com.mysql.jdbc.Driver
	*/
	Class.forName("com.mysql.jdbc.Driver");
	/*
	* 连接数据库  信息  ，用户，密码 
	*/
	Connection c = DriverManager.getConnection("jdbc:mysql://localhost:3306/login?characterEncoding=UTF-8","root","123456");
	System.out.println("数据库连接成功"+c);
	/*创建Statement 用于执行sql语句*/
	Statement s = c.createStatement();
	System.out.println("获取 Statement对象： " + s);
	/**
	* 插入语句数据  注意这里插入到表名user哦，别再是数据库名
	*/ 
    //拼接sql语句
	String sqlString = "insert into user values(null,"+"'rendonglin'"+","+"'123456789'"+")"; 
	//String deleteString = "删除语句";
	//String updateString = "修改语句";
	s.execute(sqlString);
}catch (SQLException e) {
	// TODO Auto-generated catch block
	System.out.println("数据库异常");
}catch (ClassNotFoundException e) {
	System.out.println("连接失败");
}

查询数据库所有数据并打印


//接在 Statement s = c.createStatement(); 后面即可
/**
* 查询语句,查询所有信息并打印	
*/
String selectString = "select * from user";
ResultSet rs = s.executeQuery(selectString);
while(rs.next()){
	int id = rs.getInt("id"); //可以使用字段名
	String accountString = rs.getString(2); //可以使用字段顺序
	String passwordString = rs.getString(3);
	System.out.printf("%d\t%s\t%s\n",id,accountString,passwordString);
}

验证账号密码

/**
* 校验账号密码正确，避免将数据库里的数据全部传到内存中，直接在数据库里面校验
*/
String account = "zhangyi";
//正确的密码是：123456789
String password = "0123456789";
String sql = "select * from user where account = '" + account +"' and password = '" + password+"'";
ResultSet rs = s.executeQuery(sql);
if(rs.next())
    System.out.println("账号密码正确");
else 
    System.out.println("账号密码错误");

关闭数据库

//但是得提前定义s,c；即
//Connection c = null;
//Statement s = null;
finally {
      // 数据库的连接时有限资源，相关操作结束后，养成关闭数据库的好习惯
      // 先关闭Statement
      if (s != null)
          try {
               s.close();
          } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
          }
      // 后关闭Connection
      if (c != null)
          try {
               c.close();
          } catch (SQLException e) {
               // TODO Auto-generated catch block
               e.printStackTrace();
          }
 
        }

使用事务

/*
在Mysql中，只有当表的类型是INNODB的时候，才支持事务，所以需要把表的类型设置为INNODB,否则无法观察到事务.
修改表的类型为INNODB的SQL： 
alter table hero ENGINE  = innodb;
查看表的类型的SQL 
show table status from how2java;
*/ 

// 有事务的前提下
// 在事务中的多个操作，要么都成功，要么都失败 
//操作介绍  hp 先 +1，再 -1
c.setAutoCommit(false);
  
String sql1 = "update hero set hp = hp +1 where id = 22";
s.execute(sql1);
  
// 不小心写错写成了 updata(而非update)
  
String sql2 = "updata hero set hp = hp -1 where id = 22";
s.execute(sql2);
  
// 手动提交
c.commit();

 

刚刚学习了用java连接数据库，明白了一些基础知识。过程如下：
 
 1、加载JDBC驱动程序：   
 2、提供JDBC连接的URL   
  3、创建数据库的连接   
     4、创建一个Statement   
    •要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3  
     种类型：   
      1、执行静态SQL语句。通常通过Statement实例实现。   
      2、执行动态SQL语句。通常通过PreparedStatement实例实现。
          3、执行数据库存储过程。通常通过CallableStatement实例实现。
      5、执行SQL语句   
    6、处理结果   
    两种情况：   
     1、执行更新返回的是本次操作影响到的记录数。   
     2、执行查询返回的结果是一个ResultSet对象。   
    • ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些   
      行中数据的访问。   
    • 使用结果集（ResultSet）对象的访问方法获取数据：   
   
  while(rs.next()){    
         String name = rs.getString("name") ;    
    String pass = rs.getString(1) ; // 此方法比较高效    
     }    
    （列是从左到右编号的，并且从列1开始）   

  7、关闭JDBC对象    
     操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声   
     明顺序相反：   
     1、关闭记录集   
     2、关闭声明   
     3、关闭连接对象   
     
 
 
还发现了一个给力的mysql管理工具——mysql gui tools5.0，能更加高效的管理数据库；
 
来个代码：
import java.sql.*;
import java.io.*;

public class Practice {
	public static String strCodeGtoI(String s) throws Exception {
		String str = new String(s.getBytes("GB2312"), "ISO-8859-1");
		return str;
		// 进行编码转换
		/* MySQL：ISO-8859-1，本机java：GB2312；入库时汉字须由GB2312转换为ISO-8859-1 */
	}

	public static String strCodeItoG(String s) throws Exception {
		String str = new String(s.getBytes("ISO-8859-1"), "GB2312");
		return str;
		// 进行编码转换
		// 与上面相反
	}

	public static void main(String[] args) throws Exception {
		Connection con;// 与特定数据库的连接（会话）。在连接上下文中执行 SQL 语句并返回结果。
		Statement stmt = null;// 用于执行静态 SQL 语句并返回它所生成结果的对象。
		ResultSet rs;
		// 加载驱动，这一句也可写为：Class.forName("com.mysql.jdbc.Driver");
		Class.forName("com.mysql.jdbc.Driver");
		String dbUrl = "jdbc:mysql://localhost:3306/test";
		String dbUser = "root";
		String dbPwd = "1023";
		// 建立到MySQL的连接
		con = java.sql.DriverManager.getConnection(dbUrl, dbUser, dbPwd);
		// 执行SQL语句
		stmt = con.createStatement();
		String name1 = strCodeGtoI("小王");
		String address1 = strCodeGtoI("上海");
		String sqlExpression1 = "insert into customers(name,age,address)"
				+ " values('" + name1 + "',20,'" + address1 + "')";
		stmt.executeUpdate(sqlExpression1);
		String sqlExpression2 = "select id,name,age,address from customers";
		rs = stmt.executeQuery(sqlExpression2);
		// 处理结果集
		while (rs.next()) {
			long id = rs.getLong("id");
			String name = rs.getString("name");
			short age = rs.getShort("AGE");
			String address = rs.getString("address");
			if (name != null)
				name = strCodeItoG(name);
			if (address != null)
				address = strCodeItoG(address);
			System.out.println("id=" + id + " ,name=" + name + " ,age=" + age
					+ " ,address=" + address);
		}
		// 关闭数据库
		stmt.close();
		con.close();
		rs.close();
	}

}



 
 
 
 

Java连接数据库代码

package com.hyw.util;

import java.sql.Connection;

import java.sql.DriverManager;

/**

 * 数据库工具类

 * @author f21745

 *

 */

public class DbUtil {

    

    private String dbUrl="jdbc:mysql://localhost:3306/db_book";

    private String dbUserName="admin";

    private String dbPassWord="Hyw123456";

    private String jdbcName="com.mysql.jdbc.Driver";

    

    /**

     * 获取数据库连接

     */

    public Connection getCon()throws Exception{

        Class.forName(jdbcName);

        Connection cnn=DriverManager.getConnection(dbUrl, dbUserName, dbPassWord);

        return cnn;

    }

    

    /*

     * 关闭数据库连接

     */

    public void closeCon(Connection con)throws Exception{

        if(con!=null) {

            con.close();

            

        }

        

    }

    

    public static void main(String[] args) {

        DbUtil dbUtil =new DbUtil();

        try {

            dbUtil.getCon();

            System.out.println("连接数据库成功！");

        } catch (Exception e) {

            System.out.println("连接数据库失败！");

        }

                

    }

}

显示结果：连接数据库成功！即可

Java连接数据库的几种方式
程序预览图：
第一种：最普通的方式，利用java原生jdbc连接数据库
package utils;

import java.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.PreparedStatement;
import java.sql.ResultSet;
importjava.sql.SQLException;

public class JDBCUtilsDemo1{      
       static{
              /**
               *1. 加载驱动
               */
              try {
                     Class.forName("com.mysql.jdbc.Driver");    //利用反射加载驱动
              } catch (ClassNotFoundException e) {
                e.printStackTrace();     
              }
       }
       /**
        * 2.建立连接
        */
       public static Connection getConnection() {  
              try {
                     returnDriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf-8","root", "root");
              } catch (SQLException e) {
                      throw newRuntimeException(e);
              }
       }
       /**
        * 关闭连接
        * @param conn
        * @param prep
        * @param rs
        */
       public static void close(Connection conn,PreparedStatementprep,ResultSet rs){
        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                rs = null;
            }
        }
        if(prep != null){
            try {
                prep.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                prep = null;
            }
        }
        if(conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                conn = null;
            }
        }
    }
       /**
        * 测试数据库连通性
        */
       public static void main(String[] args) {
       Connection conn=JDBCUtilsDemo1.getConnection();
              System.out.println(conn);
              JDBCUtilsDemo1.close(conn,null, null);
       }
}

第二种：利用properties.properties配置文件形式，利用java原生jdbc连接数据库

配置文件：properties.properties

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/test?characterEncoding=utf-8
username=root
password=root


源代码：

package utils;

import java.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.PreparedStatement;
import java.sql.ResultSet;
importjava.sql.SQLException;
import java.util.Properties;

public class JDBCUtilsDemo2{      
       private static Properties prop;
       static {
              prop = new Properties();
              try {
                     prop.load(JDBCUtilsDemo2.class.getClassLoader().getResourceAsStream(
                                   "db.properties"));
                     Class.forName(prop.getProperty("driver"));
              } catch (Exception e) {
                     throw new RuntimeException(e);
              }
       }
       public static Connection getConnection(Connection conn) {
              if (conn==null) {
                     try {
                            conn=DriverManager.getConnection(prop.getProperty("url"),
                                          prop.getProperty("username"),prop.getProperty("password"));
                     } catch (SQLException e) {
                            throw new RuntimeException(e);
                     }
              }
                return conn;   
       }
       public static void close(Connection conn,PreparedStatementprep,ResultSet rs){
        if(rs != null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                rs = null;
            }
        }
        if(prep != null){
            try {
                prep.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                prep = null;
            }
        }
        if(conn != null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            } finally{
                conn = null;
            }
        }
    }
public static voidmain(String[] args) {
       Connection conn = null;
       conn=JDBCUtilsDemo2.getConnection(conn);
       System.out.println(conn);
       JDBCUtilsDemo2.close(conn,null, null);
}     

}

第三种：利用c3p0-congig.xml配置文件形式，利用c3p0连接数据库
1.配置文件：c3p0-congig.xml
<c3p0-config>

       <default-config>

              <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/test</property>

              <propertyname="driverClass">com.mysql.jdbc.Driver</property>

              <propertyname="user">root</property>

              <propertyname="password">root</property>

              <propertyname="initialPoolSize">3</property>

              <propertyname="maxPoolSize">6</property>

              <propertyname="maxIdleTime">1000</property>

       </default-config>

</c3p0-config>

2.源代码：
package utils;

 

import java.sql.Connection;

importjava.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

 

import javax.sql.DataSource;

 

importcom.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCUtilsDemo3{

       /**

        * 获得一个数据源

        */

        private staticDataSource dataSource=new ComboPooledDataSource();

        public staticDataSource getDataSources() {

              return dataSource;

       }

        /**

         * 获取连接

         */

        public staticConnection getConnection(){

                try {

                     return dataSource.getConnection();

              } catch (SQLException e) {

                     throw new RuntimeException(e);

              }

        }

        /**

               * 关闭连接

               * @param conn

               * @param prep

               * @param rs

               */

              public static void close(Connectionconn,PreparedStatement prep,ResultSet rs){

               if(rs != null){

                   try {

                      rs.close();

                   } catch(SQLException e) {

                      e.printStackTrace();

                   } finally{

                       rs =null;

                   }

               }

               if(prep !=null){

                   try {

                      prep.close();

                   } catch(SQLException e) {

                      e.printStackTrace();

                   } finally{

                       prep =null;

                   }

               }

               if(conn !=null){

                   try {

                      conn.close();

                   } catch(SQLException e) {

                      e.printStackTrace();

                   } finally{

                       conn =null;

                   }

               }

           }

              /**

               * 测试数据库连通性

               */

              public static void main(String[] args) {

                     Connection conn = null;

                  conn=JDBCUtilsDemo3.getConnection();

                     System.out.println(conn);

                     JDBCUtilsDemo1.close(conn,null, null);

              }

}     

第四种：利用dbcp.properties配置文件形式，利用dbcp连接数据库
1配置文件:dbcp.properties

########DBCP配置文件##########

#####驱动名

driverClassName=com.mysql.jdbc.Driver

#####url

url=jdbc:mysql://127.0.0.1:3306/test

#####用户名

username=root

#####密码

password=root

#####初试连接数

initialSize=30

#####最大活跃数

maxTotal=30

#####最大idle数

maxIdle=10

#####最小idle数

minIdle=5

#####最长等待时间(毫秒)

maxWaitMillis=1000

####程序中的连接不使用后是否被连接池回收(该版本要使用removeAbandonedOnMaintenance和removeAbandonedOnBorrow)

#####removeAbandoned=true

removeAbandonedOnMaintenance=true

removeAbandonedOnBorrow=true

####连接在所指定的秒数内未使用才会被删除(秒)(为配合测试程序才配置为1秒)

removeAbandonedTimeout=1

2.源代码：
package utils;

import java.io.IOException;
import java.sql.Connection;
importjava.sql.PreparedStatement;
import java.sql.ResultSet;
importjava.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
importorg.apache.commons.dbcp.BasicDataSourceFactory;

public class JDBCUtilsDemo4{
       private static Properties props = new Properties();
       static {
              // 加载配置文件
              try {
                     props.load(JDBCUtilsDemo4.class.getClassLoader()
                                   .getResourceAsStream("dbcp.properties"));
              } catch (IOException e) {
                     throw new RuntimeException("配置文件加载失败");
              }
       }
       
       /**
        * 获得数据源
        *
        * @return
        */
       public static DataSource getDataSource() {
              try {
                     returnBasicDataSourceFactory.createDataSource(props);
              } catch (Exception e) {
                     throw new RuntimeException("获得数据源失败");
              }
       }
       
       /**
        * 获取连接
        *
        * @return
        */
       public static Connection getConnection() {
              try {
                     return getDataSource().getConnection();
              } catch (SQLException e) {
                     throw new RuntimeException("连接数据库失败");
              }
       }

       /**
        * 关闭连接
        *
        * @param conn
        * @param prep
        * @param rs
        */
       public static void close(Connection conn, PreparedStatementprep,
                     ResultSet rs) {
              if (rs != null) {
                     try {
                            rs.close();
                     } catch (SQLException e) {
                            e.printStackTrace();
                     } finally {
                            rs = null;
                     }
              }
              if (prep != null) {
                     try {
                            prep.close();
                     } catch (SQLException e) {
                            e.printStackTrace();
                     } finally {
                            prep= null;
                     }
              }
              if (conn != null) {
                     try {
                            conn.close();
                     } catch (SQLException e) {
                            e.printStackTrace();
                    } finally {
                            conn = null;
                     }
              }
       }

       /**
        * 测试数据库连通性
        */
       public static void main(String[] args) {
              Connection conn = null;
              conn = JDBCUtilsDemo4.getConnection();
              System.out.println(conn);
              JDBCUtilsDemo4.close(conn, null, null);
       }
}

第五种：利用mybatis-config.xml配置文件形式，利用MyBatis连接数据库
1配置文件:mybatis-config.xml
<?xmlversion="1.0" encoding="UTF-8" ?> 
<!DOCTYPEconfiguration 
  PUBLIC "-//mybatis.org//DTD Config3.0//EN" 
 "http://mybatis.org/dtd/mybatis-3-config.dtd"> 
<configuration>   
    <environmentsdefault="environment"> 
        <environmentid="environment"> 
            <transactionManager type="JDBC"/> 
            <dataSourcetype="POOLED"> 
                <propertyname="driver" value="com.mysql.jdbc.Driver" /> 
                <propertyname="url"value="jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&amp;characterEncoding=utf8"/> 
               <property name="username" value="root" /> 
                <propertyname="password" value="root" /> 
            </dataSource> 
        </environment> 
    </environments> 
     <!-- 加载SQL定义文件 -->
    <!-- <mappers> 
        <mapper resource=""/> 
    </mappers>     -->
</configuration>

2.源代码：
package utils;
importorg.apache.ibatis.session.SqlSession;
importorg.apache.ibatis.session.SqlSessionFactoryBuilder;

public class JDBCUtilsDemo5{
       private staticSqlSession session=null;
       public static SqlSession getSession(){
              try {
                     session= newSqlSessionFactoryBuilder().build(JDBCUtilsDemo5.class.getClassLoader().getResourceAsStream("mybatis-config.xml")).openSession();
              } catch (Exception e) {
                     throw new RuntimeException(e);
              }
              return session;
       }

    public static void close() {
          if(session!=null) {
                 session.close();
              }
       }

    public static void main(String[] args) {
          SqlSessionsession=null;
               session=JDBCUtilsDemo5.getSession();
               System.out.println(session);
               JDBCUtilsDemo5.close();
       }
}

第六种：利用hibernate.cfg.xml配置文件形式，利用hibernate连接数据库

1配置文件hibernate.cfg…xml
<?xml version='1.0'encoding='utf-8'?>
<!DOCTYPEhibernate-configuration PUBLIC
        "-//Hibernate/HibernateConfiguration DTD 3.0//EN"
       "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <!-- 数据库连接信息 -->         
     <propertyname="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
     <propertyname="hibernate.connection.url">jdbc:mysql://127.0.0.1:3306/test</property>
     <propertyname="hibernate.connection.username">root</property>  
     <propertyname="connection.password">root</property>
     <!-- hibernate配置信息 -->
        <!-- SQL dialect 方言，用于配置生成针对哪个数据库的-->
        <propertyname="dialect">
        <!-- 方言类，Hibernate提供的，用于封装某种特定的 -->
               org.hibernate.dialect.MySQL5Dialect
        </property>
        <!-- 生成的sql是否打印到控制台 -->
        <propertyname="show_sql">true</property> 
        <!-- 打印的sql是否进行格式化 -->    
        <propertyname="format_sql">true</property>
        <!-- 在配置文件中关联映射文件 -->
        <!-- <mappingresource=""/> -->
    </session-factory>
</hibernate-configuration>

2.源代码：
package utils;

import org.hibernate.Session;
importorg.hibernate.SessionFactory;
importorg.hibernate.cfg.Configuration;

@SuppressWarnings("deprecation")
public class JDBCUtilsDemo6{
       private static Configuration config;
       private static SessionFactory sessionFactory;
       private static Session session;
       static {
              // 1.加载hibernate.cfg.xml配置文件
              config = new Configuration().configure();
              // 2.获取SessionFactory
              sessionFactory = config.buildSessionFactory();
       }

       // 3.得到session
       public static Session getSession() {
              session = sessionFactory.openSession();
              return session;
       }
       
       // 4.关闭session
       public static void close() {
              if (session != null) {
                     session.close();
              }
       }

       public static void main(String[] args) {
              Session session = JDBCUtilsDemo6.getSession();
              System.out.println(session);
              JDBCUtilsDemo6.close();
       }
}