| 网站首页 | 业界新闻 | 小组 | 威客 | 人才 | 下载频道 | 博客 | 代码贴 | 在线编程 | 编程论坛
欢迎加入我们,一同切磋技术
用户名:   
 
密 码:  
共有 1348 人关注过本帖, 1 人收藏
标题:jdbc 里面的 UserDAO 是什么接口?
取消只看楼主 加入收藏
神龙火炬
Rank: 1
来 自:广西柳州
等 级:新手上路
帖 子:13
专家分:5
注 册:2014-11-11
结帖率:100%
收藏(1)
已结贴  问题点数:15 回复次数:0 
jdbc 里面的 UserDAO 是什么接口?
程序代码:
package com.xxx.jdbcdemo.dao;

import java.awt.List;
import java.beans.Statement;
import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.ArrayList;

import javax.xml.crypto.Data;

import com.xxx.jdbcdemo.db.DBCConnection;
import com.xxx.jdbcdemo.javabean.User;

public class UserDaoImpl   {
//定义一个数据库连接的对象
    private DBCConnection dbConnection;

    //创建数据库连接的对象
    public UserDaoImpl(){
        dbConnection=new DBCConnection();
            }
    //插入数据
    public void insertUser(User user) throws Exception{
        Connection conn=dbConnection.getConnection();
        //得到执行sql语句的对象
        java.sql.Statement sta=conn.createStatement();
        //将日期时间格式化
        String registerTime=new SimpleDateFormat("yyyy-MM-"
                + "ddhh:mm:ss").format(user.getRegisterTime());
        //拼接sql语句
        String  insertSql="insert into "
                + "user(username,password,registerTime)";
        //开始执行sql语句
        int temp=sta.executeUpdate(insertSql);
        //关闭执行sql语句
        sta.close();
        dbConnection.closeConnection(conn);
        if(temp>0){
            System.out.println("插入数据成功");
        }else{
            System.out.println("插入数据失败");
        }
        
}
    //修改数据
    public void updataUserByID(User user) throws Exception{
        Connection conn=dbConnection.getConnection();
        //得到执行sql语句的对象
        java.sql.Statement sta=conn.createStatement();
        //拼接sql语句
        String updateSql="update user set username='"
            +user.getUsername()+"'password='"+user.getPassword()
            +"'age="+user.getAge()+"where id"+user.getId();
        //开始执行sql语句
        int temp=sta.executeUpdate(updateSql);        
        //关闭执行sql语句的对象
        sta.close();
        //关闭执行sql语句的对象
        sta.close();
        dbConnection.closeConnection(conn);
        if(temp>0){
            System.out.println("修改数据成功");
        }else{
            System.out.println("修改数据失败");
        }
    }
    public void deleteUserByID(int id)throws Exception{
        //打开数据库
        Connection conn=dbConnection.getConnection();
        //得到执行sql语句的对象
        java.sql.Statement sta=conn.createStatement();
        //拼接sql语句
        String deleteSql="delete from user where id="+id;
        //开始执行sql语句
        int temp=sta.executeUpdate(deleteSql);
        sta.close();
        dbConnection.closeConnection(conn);
        if(temp>0){
            System.out.println("删除数据成功");
        }else{
            System.out.println("删除数据失败");
        }
    }
    //查询一条数据
    public User selectUserByID(int id)throws Exception{
        //打开数据库连接
        Connection conn=dbConnection.getConnection();
        java.sql.Statement sta=conn.createStatement();
        //拼接sql语句
        String selectSql="select*from user where id="+id;
        //开始执行sql语句,返回一个结果集
        ResultSet res=sta.executeQuery(selectSql);
        //遍历结果集
        //如果有数据就获取数据
        User user=null;
        if(res.next()){
            int uid=res.getInt(1);
            String name=res.getString(2);
            String pass=res.getString(3);
            int age=res.getInt(4);
            Date date=res.getDate(5);
            //封装成一个user对象
            user=new User();
            user.setId(uid);
            user.setUsername(name);
            user.setPassword(pass);
            user.setAge(age);
            user.setRegisterTime(new java.util.Date(date.getTime()));
            }
        //关闭结果集
        res.close();
        //关闭执行sql的对象
        sta.close();
        //关闭数据路链接
        dbConnection.closeConnection(conn);
        return user;
    }
    public java.util.List<User> selectAllUsers() throws Exception{
        java.util.List<User> userlist=new ArrayList<User>();
        Connection conn=dbConnection.getConnection();
        java.sql.Statement sta=conn.createStatement();
        String selectSql="select *from user";
        ResultSet res=sta.executeQuery(selectSql);
        while(res.next()){
            User user=new User();
            user.setId(res.getInt("id"));
            user.setUsername(res.getString("username"));
            user.setPassword(res.getString("password"));
            user.setAge(res.getInt("age"));
            user.setRegisterTime(res.getDate("registerTime"));
            userlist.add(user);
            
        }
        res.close();
        sta.close();
        dbConnection.closeConnection(conn);
        return userlist;
    }
}

package com.xxx.jdbcdemo.javabean;

import  java.util.Date;

import javax.xml.crypto.Data;

public class User implements Serializable {
    private static final long serialiVersionUID=1L;
    private int id;
    private String username;
    private String password;
    private int age;
    private Date registerTime;
    
    public int getId(){
        return id;
        
    }
    public void setId(int id){
        this.id=id;
    }
    public String getUsername(){
        return username;
    }
    public void setUsername(String username){
        this.username=username;
    }
    public String getPassword(){
        return password;
    }
    public void setPassword(String password){
        this.password=password;
    }
    public int getAge(){
        return age;
    }
    public void setAge(int age){
        this.age=age;
    }
    public void setRegisterTime(Date registerTime){
        this.registerTime=registerTime;
    }
    public Date getRegisterTime() {
        // TODO 自动生成的方法存根
        return registerTime;
    }
    
    


}
[code]
package com.xxx.jdbcdemo.db;

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

public class DBCConnection {
    //数据库驱动名称
public static final String DRIVER_NAME=
"com.mysql.jdbc.Driver";
//数据库链接地址
public static final String URL="jdba:mysql://localhost:3306/test";
//登陆数据库用户名
public static final String USERNAME="root";
public static final String PASSWORD="123456";

//静态块
static{
    try{
        //加载数据库驱动类
        Class.forName(DRIVER_NAME);
        }catch(ClassNotFoundException e){
            throw new ExceptionInInitializerError(e);
        }
}
//获取数据库连接
public Connection getConnection(){
    Connection conn=null;
    try{
        //建立连接
        conn=DriverManager.getConnection(URL,USERNAME,PASSWORD);
        if(conn!=null){
            System.out.println("连接成功!");
        }else{
            System.out.println("连接失败!");
        }
    }catch(Exception e){
        e.printStackTrace();
    }
    return conn;
    
}
//关闭数据库链接
public void closeConnection(Connection conn){
    try{
        if(conn!=null){
            //关闭数据库
            //使用connection对象调用close
            conn.close();
            conn=null;
        }
        }catch(SQLException e){
            e.printStackTrace();
    }
}
}


[/code]
搜索更多相关主题的帖子: import 接口 
2014-12-05 23:50
快速回复:jdbc 里面的 UserDAO 是什么接口?
数据加载中...
 
   



关于我们 | 广告合作 | 编程中国 | 清除Cookies | TOP | 手机版

编程中国 版权所有,并保留所有权利。
Powered by Discuz, Processed in 0.041930 second(s), 8 queries.
Copyright©2004-2024, BCCN.NET, All Rights Reserved