从0到1学JAVA之第五天——JDBC分离Interface和Imple实现对数据库增删改查,

DataBase 一零 2年前 (2017-11-15) 201次浏览 0个评论

今天完成的任务

利用 jdbc 实现对数据库的增删改查。

代码已经上传 github,gayhub 链接

1.数据表设计:

2.blog\JobDAO.java              #定义 job 表的数据操作接口

package blog;

public interface JobDAO {
      public int insert(String jname,int number,long create_at,long update_at);
      public int update(String jname,int number);
      public int delete(String jname);
      public void select(String jname);
}

 3.blog\JobDAOImpl.java        #定义 Job 表的数据操作类,实现 JobDAO 接口,包括增删改查

package blog;
import java.sql.PreparedStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;
import java.util.*;
public  class JobDAOImpl implements JobDAO{
        private Connection conn;
        private PreparedStatement psjob;
        private Statement jobinfo;
        private ResultSet results;
        long time = new Date().getTime();
        //插入数据
        public int insert(String jname, int number, long create_at,long update_at){
        	int result = 0;
        	conn = ConnectionManager.getConnection();
        	try{
        		String sql = "insert into yl_job (jname,number,create_at,update_at)values(?,?,?,?)";
        		psjob = conn.prepareStatement(sql);
        		psjob.setString(1, jname);
        		psjob.setInt(2, number);
        		psjob.setLong(3, create_at);
        		psjob.setLong(4, update_at);
        		result = psjob.executeUpdate();
        	}catch(SQLException e){
        		e.printStackTrace();
        	}finally{
        		ConnectionManager.closeStatement(psjob);
        		ConnectionManager.closeConnection(conn);
        	}
        	return result;
        }
        //更新 job 的 数目
        public int update(String jobName, int number){
        	int result = 0;
        	conn = ConnectionManager.getConnection();
        	try{
        		String sql = "update yl_job set number=?,update_at=? where jname=?";
        	    psjob = conn.prepareStatement(sql);
        		psjob.setInt(1, number);
        		psjob.setLong(2, time);
        		psjob.setString(3, jobName);
        		result = psjob.executeUpdate();
        	}catch(SQLException e){
        		e.printStackTrace();
        	}finally{
        		ConnectionManager.closeStatement(psjob);
        		ConnectionManager.closeConnection(conn);
        	}
        	return result;
        }
        //根据 job name 删除 job
        public int delete(String jobName){
        	int result = 0;
        	conn = ConnectionManager.getConnection();
        	try{
        		String sql = "delete from yl_job where jname=?";
        		psjob = conn.prepareStatement(sql);
        		psjob.setString(1, jobName);
        		result = psjob.executeUpdate();
        	}catch(SQLException e){
        		e.printStackTrace();
        	}finally{
        		ConnectionManager.closeStatement(psjob);
        		ConnectionManager.closeConnection(conn);
        	}
        	return result;
        }
        //从数据库查询数据
        public void select(String jobName){
        	conn = ConnectionManager.getConnection();
        	try{
        		String sql = "select * from yl_job where jname = '"+jobName+"'";
        		jobinfo = conn.createStatement();
        		ResultSet results = jobinfo.executeQuery(sql);
        		while(results.next()){
        			System.out.println(results.getString("jid")+" "+results.getString("jname")+" "+results.getString("create_at")
        			+" "+results.getString("update_at") );
        		}
        	}catch(SQLException e){
        		e.printStackTrace();
        	}
        }

}

4.blog\TestJob.java               #测试JobDAOImpl.java 类中的方法

package blog;
import java.util.*;
public class TestJob {
 public static void main(String[] args){
 JobDAO jobdao = new JobDAOImpl();
 long time = new Date().getTime();
 int res;
 res = jobdao.insert("JAVA 架构师", 3, time, time);
 if(res>0)
 System.out.println("插入成功, 插入"+res+"条");
 else
 System.out.println("插入失败!!!");
 res = jobdao.update("JAVA 架构师", 13);
 if(res>0)
 System.out.println("更新成功!");
 else
 System.out.println("更新失败!!!");
 res = jobdao.delete("JAVA 架构师");
 if(res>0)
 System.out.println("删除成功!");
 else
 System.out.println("删除失败!!!");
 jobdao.select("JAVA 研发工程师");
 }
}

 5.控制台输出结果

明天计划的任务

1.学习 MyBatis。

遇到的问题

1.存入数据的中文显示为三个???

在连接数据库的 url 后面添加参数:

private static final String DATABASE_URL="jdbc:mysql://localhost:3306/ylxjava?useUnicode=true&characterEncoding=utf8";

2.错误:java.sql.SQLException:Column count doesn’t match value count at row 1

错误原因:在插入数据时,插入的 VALUE 的字段数跟数据库表字段个数不一致

3.如何获取当前时间戳?

注意:import java.util.date;    #引入 date 库
new Date().getTime();

4.错误:The type Date is ambiguous

意思是“Date 类型不明确”,其实是因为冲突造成的。在该文件中,一零同时引入了 java.sql.* 和 java.util.*,但是两个钟中都存在着 Date 类型,编译器不清楚使用哪一个,于是报错。

解决办法,将需要的 sql 的包一个一个引入。

import java.sql.Connection;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.*;

5.错误:com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Unknown column

在操作数据库时 String 类型的参数必须要用’ ‘把参数引起来才能传递并接收!此处一零上传的参数是 String 类型,错误原因是没有加单引号。因此,在进行数据库操作时,千万不要漏了两边的单引号。

String sql = "select * from yl_job where jname = '"+jobName+"'";

收获

1.熟悉了利用 JDBC 对数据库实现增删改查。

2.学习了如果实现 Interface 和 Imple 的分离


爱码星 , 版权所有丨如未注明 , 均为原创丨本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:从 0 到 1 学 JAVA 之第五天——JDBC 分离 Interface 和 Imple 实现对数据库增删改查,
喜欢 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到