欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

JAVA使用JDBC技术操作SqlServer数据库实例代码

程序员文章站 2024-03-08 18:04:58
jdbc(java data base connectivity,java数据库连接)是一种用于执行sql语句的java api,可以为多种关系数据库提供统一访问,它由一组...

jdbc(java data base connectivity,java数据库连接)是一种用于执行sql语句的java api,可以为多种关系数据库提供统一访问,它由一组用java语言编写的类和接口组成。jdbc提供了一种基准,据此可以构建更高级的工具和接口,使数据库开发人员能够编写数据库应用程序。 jdbc并不能直接访问数据库,需要借助于数据库厂商提供的jdbc驱动程序。 

数据库连接

如果要在java访问数据库,首先要加载一个数据库驱动,数据库驱动只需要在第一次访问时加载一次。然后再每次访问数据库时创建一个connection实例,获取数据库连接,这样就可以执行操作数据库的sql语句。最后用完后释放掉数据库的连接。

数据库驱动类

不同的数据库实现jdbc接口不同,所以就产生了不同的数据库驱动包。驱动包就包含一些负责数据库连接的类,把我们要操作的sql语句传递到里面去。我的pc用的是sql2012,所以我们要去这里http://www.microsoft.com/zh-cn/search/downloadresults.aspx?q=jdbc下载驱动

下完后在新建的java_project导入驱动包

JAVA使用JDBC技术操作SqlServer数据库实例代码

右击选中项目>>build path >>add external archives... 选中下载解压的文件

JAVA使用JDBC技术操作SqlServer数据库实例代码


导入成功后的项目:

JAVA使用JDBC技术操作SqlServer数据库实例代码

package com.project_database01;

import java.sql.connection;
import java.sql.drivermanager;

public class selectquery {
 
 private connection conn;
 
 /*
  * 创建一个返回connection的方法
  */
 public connection getconnection(){
  try {
   class.forname("com.microsoft.sqlserver.jdbc.sqlserverdriver");
   system.out.println("数据库驱动加载成功");
   conn=drivermanager.getconnection("jdbc:sqlserver://localhost:1433;databasename=java_conn_test","sa","123456");
   if(conn==null){
    system.out.println("数据库连接失败");
    system.out.println("-----------------------");
   }else {
    system.out.println("数据库连接成功");
    system.out.println("-----------------------");
   }
  } catch (exception e) {
   // todo: handle exception
   e.printstacktrace();
  }
  return conn;
 }

} 

进行sqlserve数据库java_conn_test中的tb_user进行数据的增删改查。

 package com.project_database01;

import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.statement;

public class startmain {
 
 private static connection conn;

 public static void main(string[] args) {
  // todo auto-generated method stub
  
  conn=new selectquery().getconnection();
  
  getinsert();
  getselect();
  
  getupdate();
  getselect();
  
  getdelete();
  getselect();
 }

 /*
  * insert
  */
 public static void getinsert(){
  if(conn!=null){
   //insert 
   system.out.println("-----------insert------------");
   int x=1+(int)(math.random()*5000);
   string insert_str="insert into tb_user (username,userpwd,userid) values ('name_"+x+"','pwd_"+x+"',newid())";
   try {
    statement insertstatement=conn.createstatement();
    int result= insertstatement.executeupdate(insert_str);
    if(result>0){
     system.out.println("添加成功");
     system.out.println("-----------------------");
    }
    else {     
     system.out.println("添加失败");
     system.out.println("-----------------------");
    }
   } catch (exception e) {
    system.out.println("添加失败");
    system.out.println("-----------------------");
    // todo: handle exception
   }
  }
  else {
   system.out.println("请检查数据库连接");
   system.out.println("-----------------------");
  }
 }
 
 /*
  * select
  */
 public static void getselect(){
  if(conn!=null){
   
   //select
   system.out.println("-----------select------------");
   string select_str=" select * from tb_user ";
   try {
    preparedstatement selectps=conn.preparestatement(select_str);
    resultset rs=selectps.executequery();
    while (rs.next()) {
     string name=rs.getstring("username");
     string pwd=rs.getstring("userpwd");
     string userid=rs.getstring("userid");
     system.out.println(name+"\t"+pwd+"\t"+userid);
    }
    system.out.println("查询成功");
    system.out.println("-----------------------");
   } catch (exception e) {
    // todo: handle exception
    system.out.println("查询失败");
    system.out.println("-----------------------");
   }
  }
  else {
   system.out.println("请检查数据库连接");
   system.out.println("-----------------------");
  }
 }

 /*
  * update
  */
 public static void getupdate(){
  if(conn!=null){
   //update
   system.out.println("-----------insert------------");
   string update_str="update tb_user set userpwd=userpwd+'xxxxxxxx' where userid='fa562573-218a-4205-b67d-ebdfac3f8329'";
   try {
    statement updatestatement=conn.createstatement();
    int result=updatestatement.executeupdate(update_str);
    if(result>0){
     system.out.println("修改成功!");
     system.out.println("-----------------------");
    }else {
     system.out.println("修改失败");
     system.out.println("-----------------------");
    }
   } catch (exception e) {
    // todo: handle exception
    system.out.println("修改失败");
    system.out.println("-----------------------");
   }
  }
  else {
   system.out.println("请检查数据库连接");
   system.out.println("-----------------------");
  }
 }
 
 /*
  * delete
  */
 public static void getdelete(){
  if(conn!=null){
   //delete 
   system.out.println("-----------delete------------");
   string delete_str="delete tb_user where userid!='fa562573-218a-4205-b67d-ebdfac3f8329'";
   try {
    statement deletestatement=conn.createstatement();
    int result=deletestatement.executeupdate(delete_str);
    if(result>0){
     system.out.println("删除成功!");
     system.out.println("-----------------------");
    }else {
     system.out.println("删除失败");
     system.out.println("-----------------------");
    }
   } catch (exception e) {
    // todo: handle exception
    system.out.println("删除失败");
    system.out.println("-----------------------");
   }
  }
  else {
   system.out.println("请检查数据库连接");
   system.out.println("-----------------------");
  }
 }

} 

运行程序:

JAVA使用JDBC技术操作SqlServer数据库实例代码

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。