首页 > 代码库 > Java程序操作数据库SQLserver详解

Java程序操作数据库SQLserver详解

        数据库基本操作:增删改查(CRUD)


crud介绍(增、删、改、查操作)


     CRUD是指在做计算处理时的增加(Create)、查询(Retrieve)(重新得到数据)、更新(Update)和删除(Delete)几个单记事的首字母简写。主要被用在描述软件系统中数据库或者持久层的基本操作功能。

 Create new records

 Rctricvc cxisting rccords

 Update existing records

 Delete existing records.


要对数据表进行增、删、改、查,我们首先要清楚jdbc基本的概念:

技术分享


技术分享


    JDBC有两种,一种原sun公司提供的数据库连接api但不是直接连接sql server而是先连接ODBC再通过ODBC对sql server进行操作;一种是由微软提供的JDBC数据库连接api可直接对sqlserver数据库进行操作。

    JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用程序,同时,JDBC也是个商标名。

    有了JDBC,向各种关系数据发送SQL语句就是一件很容易的事。换言之,有了JDBC API,就不必为访问Sybase数据库专门写一个程序,为访问Oracle数据库又专门写一个程序,或为访问Informix数据库又编写另一个程序等等,程序员只需用JDBC API写一个程序就够了,它可向相应数据库发送SQL调用。同时,将Java语言和JDBC结合起来使程序员不必为不同的平台编写不同的应用程序,只须写一遍程序就可以让它在任何平台上运行,这也是Java语言“编写一次,处处运行”的优势。

注:JDBC访问不同的数据库使用的JDBC API都有所不同,虽然统称为JDBC。如:访问sql server数据库的JDBC,是不能访问oracle数据库的,同理也是也不访问mysql、db2、Informix数据库等。只是访问方式不同,对数据库的操作依然是使用sql语句操作

    Java 具有坚固、安全、易于使用、易于理解和可从网络上自动下载等特性,是编写数据库应用程序的杰出语言。所需要的只是 Java应用程序与各种不同数据库之间进行对话的方法。而JDBC 正是作为此种用途的机制。

 

jdbc的驱动的分类

目前比较常见的JDBC驱动程序可分为以下四个种类

1、jdbc-odbc桥连接

2、本地协议纯java驱动程序

3、网络协议纯java驱动程序

4、本地api

 

jdbc不足

尽管JDBC在JAVA语言层面实现了统一,但不同数据库仍旧有许多差异。为了更好地实现跨数据库操作,于是诞生了Hibernate项目,Hibernate是对JDBC的再封装,实现了对数据库操作更宽泛的统一和更好的可移植性。

 

java操作sql server数据库(表)

技术分享


1、我们先使用jdbc-odbc桥连的方式来操作sql server数据库(表)完成对people表的crud操作

源码如下:

/**
 * 演示使用jdbc-odbc桥连方式操作sql server数据库
 * 具体操作jdbc数据库的people表
 * 1、配置数据源--windows下在控制面板-->管理工具-->ODBC数据源-->用户DSN--添加
 *    sql server
 * 2、在程序中去连接数据源
 * 3、使用Statement(不安全)连接数据库
 */
import java.sql.*;
public class Jdbc_test {
	public static void main(String[] args) {
		Connection ct=null;
		Statement sm=null;
		ResultSet rs=null;
		try {
			//1、加载驱动(把需要的驱动程序加入内存)
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                        //2、得到连接(指定连接到哪个数据源、数据库的用户名和密码)
			//如果配置数据源的时候选择的是windows NT验证方式,则不需要数据库的用户名和密码
		     ct=DriverManager.getConnection("jdbc:odbc:ywq");
//			ct=DriverManager.getConnection("jdbc:odbc:mytest","sa","sa");

                       //3、创建Statement或者PreparedStatement(区别)
			//Statement用处:主要用于发送SQL语句到数据库
			sm=ct.createStatement();

                        //4、执行(CRUD,创建数据库、备份数据库、删除数据库)
                        //演示1:添加一条数据到dept表中
			//executeUpdate可以执行CUD操作(添加、删除、修改)
//			int i=sm.executeUpdate("insert into people values(25,‘张三‘,‘男‘)");
//			int q=sm.executeUpdate("insert into people values(20,‘李四‘,‘男‘)");
//			int z=sm.executeUpdate("insert into people values(30,‘小三‘,‘女‘)");
//			if(i==1&&q==1&&z==1){
//				System.out.println("数据添加成功");
//			}else{
//				System.out.println("添加失败");
//			}
			
			//演示2:从dept表中删除一条记录
//			int j=sm.executeUpdate("delete from people where age=25");
//			System.out.println(j);
//			//此处j的值为本次删除的记录条数
//			if(j==1){
//				System.out.println("数据删除成功");
//			}else{
//				System.out.println("删除失败");
//			}
			
			//演示3:从people表中修改age=20 name改为李四他爹
//			int k=sm.executeUpdate("update people set name=‘李四他爹‘ where age=‘20‘");
//			if(k==1){
//				System.out.println("数据修改成功");
//			}else{
//				System.out.println("修改失败");
//			}
			
			//演示4:查询,显示所有的部门信息
			//ResultSet结果集,大家可以把ResultSet理解成返回一张表行的结果集
			rs=sm.executeQuery("select * from people");
			//循环取出
			while(rs.next()){
				int a=rs.getInt(1);
				String b=rs.getString(2);
				String c=rs.getString(3);
				System.out.println(a+"\t"+b+"\t"+c);	
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			//关闭资源,关闭顺序:先创建后关闭,后创建先关闭
			try {
				//为了程序健壮
				if(rs!=null){
					rs.close();
				}
				if(sm!=null){
					sm.close();
				}
				if(ct!=null){
					ct.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}

首先是数据源的配置,步骤如下图所示:

技术分享

其中,名称为数据源的名称,即程序ct=DriverManager.getConnection("jdbc:odbc:ywq");中使用的ywq名称。

下一步:

技术分享

有俩种方式,本例使用了Windows验证方式不需要密码和用户名。

下一步:

技术分享

选择你要使用的数据库,即你要操作的people表必须在这个数据库中。


至此完成了数据源的配置。开始进行正式的Java程序操作sqlserver数据库

操作数据库步骤:

1、加载驱动

Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

2、得到连接(指定连接到哪个数据源、数据库的用户名和密码)。如果配置数据源的时候选择的是windows NT验证方式,则不需要数据库的用户名和密码

    方式1: ct=DriverManager.getConnection("jdbc:odbc:ywq");
     方式2:ct=DriverManager.getConnection("jdbc:odbc:ywq","sa","sa");     后边为数据库的用户名和密码

3、创建Statement或者PreparedStatement(区别) 参考http://blog.csdn.net/qq_25827845/article/details/50675388
用处:主要用于发送SQL语句到数据库(可理解为火箭车,发送SQL数据)

        sm=ct.createStatement();

4、进行CRUD操作。


     我们使用查询分析器来创建数据库jdbc以及people表。

create database jdbc

create table people
(
  age int,
  name nvarchar(50),
  sex  nvarchar(2)  
)

执行后便创建成功。是一个空表。

通过演示1,将几条数据插入表中

//演示1:添加一条数据到people表,executeUpdate可以执行CUD操作(添加、删除、修改)

            int i=sm.executeUpdate("insert into people values(25,‘张三‘,‘男‘)");
            int q=sm.executeUpdate("insert into people values(20,‘李四‘,‘男‘)");
            int z=sm.executeUpdate("insert into people values(30,‘小三‘,‘女‘)");
            if(i==1&&q==1&&z==1){
                System.out.println("数据添加成功");
            }else{
                System.out.println("添加失败");
            }

可看到数据插入成功技术分享

演示2:从people表中删除一条记录

            int j=sm.executeUpdate("delete from people where age=25");

            System.out.println(j);
            //此处j的值为本次删除的记录条数
            if(j==1){
                System.out.println("数据删除成功");
            }else{
                System.out.println("删除失败");
            }

数据删除成功。

技术分享


演示3:从people表中修改age=20的数据,将 name改为李四他爹

            int k=sm.executeUpdate("update people set name=‘李四他爹‘ where age=‘20‘");

            if(k==1){
                System.out.println("数据修改成功");
            }else{
                System.out.println("修改失败");
            }

修改成功。

技术分享


演示4:查询,显示所有的部门信息,ResultSet结果集,大家可以把ResultSet理解成返回一张表行的结果集

            rs=sm.executeQuery("select * from people");

            //循环取出
            while(rs.next()){

                int a=rs.getInt(1);

                String b=rs.getString(2);

                String c=rs.getString(3);

                System.out.println(a+"\t"+b+"\t"+c);    
            }

查询成功

技术分享


下边演示使用更安全更高效的PreparedStatement实现CRUD操作,源码如下:

/**
 * PreparedStatement使用CRUD
 * 1、PreparedStatement可以提高执行效率(因为它有预编译的功能)
 * 2、PreparedStatement可以防止SQL注入,但是要求用?赋值的方式才可以
 */

import java.sql.*;
public class Test_2 {
	public static void main(String[] args) {
		Connection ct=null;
		PreparedStatement ps=null;
		ResultSet rs=null;
		try {
			//1、加载驱动(把需要的驱动程序加入内存)
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
			//2、得到连接(指定连接到哪个数据源、数据库的用户名和密码)
			ct=DriverManager.getConnection("jdbc:odbc:ywq");
			//3、创建PreparedStatement
			//PreparedStatement用处:主要用于发送SQL语句到数据库
			ps=ct.prepareStatement("select * from people where age=? and name=?");
			//给?赋值(可防止SQL注入漏洞问题),不要直接使用拼接的方式
			ps.setInt(1, 30);
			ps.setString(2, "小三");
//			//演示1:查询,显示所有的部门信息
			//ResultSet结果集,大家可以把ResultSet理解成返回一张表行的结果集
			rs=ps.executeQuery();
			//循环取出
			while(rs.next()){
				int a=rs.getInt(1);
				String b=rs.getString(2);
				String c=rs.getString(3);
				System.out.println(a+"\t"+b+"\t"+c);	
			}
			
			
			//演示2、使用PreparedStetement添加一条记录
//			ps=ct.prepareStatement("insert into people values(?,?,?)");
//			ps.setInt(1, 60);
//			ps.setString(2, "小六");
//			ps.setString(3, "男");
//			//执行
//			int i=ps.executeUpdate();
//			if(i==1){
//				System.out.println("添加成功");
//			}else{
//				System.out.println("添加失败");
//			}
			
			//演示3、使用PreparedStetement修改一条记录从people表中修改name=小六 name改为小七
//			ps=ct.prepareStatement("update people set age=? where name=‘小六‘");
//			ps.setInt(1, 45);			
//			//执行
//			int i1=ps.executeUpdate();
//			if(i1==1){
//				System.out.println("修改成功");
//			}else{
//				System.out.println("修改失败");
//			}
			
			//演示4、使用PreparedStetement删除一条记录
			ps=ct.prepareStatement("delete from people where age=?");
			ps.setInt(1, 45);
			int i=ps.executeUpdate();
			if(i==1){
				System.out.println("删除成功");
			}else{
				System.out.println("删除失败");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			//关闭资源,关闭顺序先创建后关闭,后创建先关闭
			try {
				if(rs!=null){
					rs.close();
				}
				if(ps!=null){
					ps.close();
				}
				if(ct!=null){
					ct.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}

这段代码应该很好理解,同时这也是我们更常用的写法,通常我们将使用PreparedStatement而不是Statement。


2、使用jdbc驱动程序直接操作sql server数据库(表)完成对people表的CRUD操作。


不使用odbc,直接通过jdbc来连接数据库,俩者只有俩处不相同。

(1)加载驱动                   (2)得到连接时

JDBC-ODBC桥连操作sql server与JDBC驱动直连操作sql server的区别:

1、JDBC-ODBC桥连sql server无需引入外部驱动

2、JDBC直连需要引入微软提供的JDBC驱动

 

JDBC方式去操作数据库

 1、引入sql包

2、sqlserver2000需要引入三个jar包,分别是msbase.jar和mssqlserver.jar和msutil.jar

  3、sqlserver2005/2008/2012版本中可以引入sqljdbc.jar或sqljdbc4.jar两个微软提供的JDBC包,官方目前推出2.0/3.0/4.0版本

 *4、使用sqljdbc4.jar后可以不使用加载驱动Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");而直接连接数据库

  5、使用sqljdbc.jar则需要加载驱动

 *6、特别说明,如果取值是按编号取,则需一一对应;如果按字段列名取值,则可以灵活取值


           //1、加载驱动

            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

            //2、得到连接

         ct=DriverManager.getConnection("jdbc:sqlserver://127.0.0.1:1433;databaseName=ywq;");

            if(!ct.isClosed()){

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

            }else{

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

            }

通过此种方式便建立了与数据库的连接。其它保持不变。


3、java程序中来控制对数据库(表)的创建、删除、备份、恢复工作

/**
 * 在java中如何使用ddl语句(credate(创建),drop(删除),backup(备份),restore(恢复))数据库
 */

import java.sql.*;
public class Test_3 {
	public static void main(String[] args) {
		//定义需要的对象
		PreparedStatement ps=null;
		Connection ct=null;
		ResultSet rs=null;
		try {
			//1、加载驱动
			Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
			//2、得到连接
			ct=DriverManager.getConnection("jdbc:sqlserver://127.0.0.1:1433;databaseName=ywq;");
			if(!ct.isClosed()){
				System.out.println("数据库连接成功");
			}else{
				System.out.println("数据库连接失败");
			}
//			//3、创建ps,创建数据库
//			ps=ct.prepareStatement("create database vvv");
//			//如果执行的是ddl语句
//			if(!ps.execute()){
//				System.out.println("创建数据库成功");
//			}else{
//				System.out.println("创建数据库失败");
//			}
			//4、创建ps,创建表
//			ps=ct.prepareStatement("create table xxx(aa int)");
//			//如果执行的是ddl语句
//			if(!ps.execute()){
//				System.out.println("创建表成功");
//			}else{
//				System.out.println("创建表失败");
//			}
			//5、备份数据库
//			ps=ct.prepareStatement("backup database vvv to disk=‘e:/vvv.bak‘");
//			if(!ps.execute()){
//				System.out.println("备份数据库成功");
//			}else{
//				System.out.println("备份数据库失败");
//			}
			//6、恢复数据库
			ps=ct.prepareStatement("restore database vvv from disk=‘e:/vvv.bak‘");
			if(!ps.execute()){
				System.out.println("恢复数据库成功");
			}else{
				System.out.println("恢复数据库失败");
			}
			
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();
				}
				if(ps!=null){
					ps.close();
				}
				if(ct!=null){
					ct.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
}

其实,用Java程序来操作SQLserver数据库和在查询分析器中对数据库进行查询原理一样。Java中只要掌握了那4个步骤,即:加载驱动,得到连接,创建火箭车,执行CRUD,恢复备份等操作。即可完美操作数据库。


新技能,get!!!












Java程序操作数据库SQLserver详解