zoukankan      html  css  js  c++  java
  • java项目连接access数据库

    1.导入Access_JDBC30.jar到项目中

    jar包百度云链接:https://pan.baidu.com/s/10HFM3HomMArvfHjklA_1MA 密码:0qxp

    项目名称-》右键-》build path-》add extra jar -》Access_JDBC30.jar

    2.代码如下:

    
    package userpackage;
    import java.sql.*;
    
    import topicpackage.*;
    import actorpackage.*;
    import administratorpackage.*;
    import answerpackage.*;
    import exceptionpackage.*;
    
    public class UserDA {
    
      //connection DB
        public static Connection initialize()
        {
        try
        		{
        	//loading jdbc-odbc bridge driver
        	try{
        	Class.forName("com.hxtt.sql.access.AccessDriver").newInstance();
        	}
        	catch(InstantiationException e){
        		e.printStackTrace();
        	}
        	catch(IllegalAccessException e){
        		e.printStackTrace();
        	}
        	//
        	aConnection=DriverManager.getConnection("jdbc:Access:///D:/UserT.accdb");
        	aStatement=aConnection.createStatement();
    
        		}
        catch(ClassNotFoundException e)
        		{
        		System.out.println(e);
        		}
        catch(SQLException e)
        		{
        		System.out.println(e);
        		}
        return aConnection;
        	}
        /*释放资源*/
        public static void terminate(){
        	try{
        		aStatement.close();
        		aConnection.close();
        	}
        	catch(SQLException e){
        		System.out.println(e);
        	}
        }
        /*添加一个新记录*/
        public static void add(User aUser) throws DuplicateException{
        
        	String sql = "INSERT INTO UserT "
        	+"VALUES('"+userID+"','"+name+"','"+passWord+"','"+gender+"','"+image+"','"+isFrozen+"')";
        	System.out.println(sql);
        	
        	try{
        		User c = find(userID);
        		throw(new DuplicateException("该用户已存在"));
        	}
        	
        	catch (NotFoundException e){
        		try{
        			int result = aStatement.executeUpdate(sql);
        		}
        		catch(SQLException ee){
        			System.out.println(ee);
        		}
        	}
        	}
    
    
        	public static User find(String key) throws NotFoundException
        	{
        		//retrieve Answer
        		aUser=null;
        		//define the SQL query statement using the phone number key
        		String sql="SELECT UserID,passWord,uname,image,gender,isFrozen FROM UserT"+" WHERE UserID= '"+key+"'";
        		//execute the SQL query statement
        		System.out.println(sql);
        		try
        		{
        			ResultSet rs =aStatement.executeQuery(sql);
        			
        			//next method sets cursor & returns true if there is data
        			boolean gotIt=rs.next();
        			if(gotIt)
        			{
        			//extract the data
        				userID=rs.getString(1);
        				name=rs.getString(2);
        				passWord=rs.getString(3);
        				gender=rs.getString(4);
        				image=rs.getString(5);
        				isFrozen=rs.getString(6);
        				
        				
        				aUser=new User(userID,name,passWord,gender,image,Boolean.valueOf(isFrozen));
        				
        			}
        			else throw(new NotFoundException("没有发现这个记录"));
        			rs.close();
        			}
        		
        			catch(SQLException e)
        			{
        				System.out.println(e);
        			}
        		return aUser;
        		}
        public static void delete(User aUser){
        	userID = aUser.getUserID();
        	String sql = "DELETE FROM UserDT"+"WHERE userID = '"+userID+"'";
        	try{
        		int result = aStatement.executeUpdate(sql);
        	}
        	catch (SQLException e){
        		System.out.println(e);
        	}
        }
        public static void update(User aUser) throws NotFoundException
        {
        	userID=aUser.getUserID();
        	name=aUser.getName();     //全部转化为字符串类型
        	passWord=aUser.getPassWord();
        	gender=aUser.getGender();
        	image=aUser.getImage();
        	isFrozen= ""+aUser.getIsFrozen();
        
        	String sql="Update AnswerT SET isFrozen = '"+isFrozen+"',"+
        	" Name = '"+name+"',"+
        	" PassWord = '"+passWord+"',"+
        	" Gender = '"+gender+"',"+
        	" Image = '"+image+"',"+
        	
        	"WHERE id='"+userID+"'";
        	System.out.println(sql);
        	try
        	{
        		int result=aStatement.executeUpdate(sql);
        	}
        	catch(SQLException e)
        	{
        		System.out.println(e);
        	}
        	}
    
    
    
    }
    
    
    
  • 相关阅读:
    .net core 3.1 过滤器(Filter) 和中间件和AOP面向切面拦截器
    socket通信框架——boost asio
    远程过程调用框架——gRPC
    数据序列化工具——flatbuffer
    springboot项目启动----8080端口被占用排雷经过
    如何配置HOSTS文件
    使用线程Callable实现分段获取一个url连接的资源数据
    Socket网络编程课件
    (6)优化TCP编写 服务器端同时支持多个客户端同时访问
    SpringBoot配置属性之Security
  • 原文地址:https://www.cnblogs.com/YuQiao0303/p/9277567.html
Copyright © 2011-2022 走看看