首页 > 分享 > JDBC连接数据库

JDBC连接数据库

萌宠菠菠乐园
2024-10-25 10:26

Java Database Connectivity

概念

JAVA数据库连接技术

主要功能

1.与数据库建立连接、执行SQL语句、处理结果

DAO模式(Data Access Object(数据存取对象) )

数据持久化的概念

将程序中的数据在瞬时状态和持久状态间转换的机制即为数据的持久化

JDBC封装

1.提高可读性

2.利于后期维护与修改

3.增强代码的复用性

4.降低代码之间的耦合

5.隔离业务逻辑代码与数据库访问代码

6.隔离不同的数据库的实现

JDBC封装步骤

定义实体类

public class Pet{ private int id;// 宠物id private int masterId;// 主人id private String name;// 昵称 …… public int getId(){ return id; } public void setId(int id){ this.id = id; } …… }

对实体类的所有操作抽取成接口

public interface PetDao{ int save(Pet pet); int del(Pet pet); int update(Pet pet); Pet getByName(String name); List<Pet> findByName(String name); List<Pet> findByType(String type);}

创建BaseDAO(待改良)

public class BaseDao{ private String driver = " com.mysql.jdbc.Driver"; private String url = "jdbc:mysql://localhost:3306/epet"; … … public Connection getConnection() { … … Class.forName(driver); conn = DriverManager.getConnection(url, user, password); … … return conn; } public void closeAll(Connection conn, Statement stmt,ResultSet rs) { if(rs != null) rs.close(); if(stmt != null)stmt.close(); … … } public int exceuteUpdate (String preparedSql, Object[] param) { … … conn = getConnection(); try { pstmt = conn.prepareStatement(preparedSql); if (param != null) { for (int i = 0; i < param.length; i++) { //为预编译sql设置参数 pstmt.setObject(i + 1, param[i]); } } num = pstmt.executeUpdate(); } … … } }

实现类实现接口并继承数据库工具类

public class PetDaoMySQLImpl2 extends BaseDao implements PetDao{ //更新宠物状态 public int update(Pet pet) { String sql="update pet set status=0 where id=?"; Object[] param={pet.getId()}; int result=this.exceuteUpdate(sql, param); return result; } //省略实现PetDao的其他方法 } 使用Properties类

添加.properties文件

调用properties方法

String getProperty(String key)//用指定的键在此属性列表中搜索属性。通过参数key得到其所对应的值 Object setProperty(String key,String value)//调用Hashtable的方法put。通过调用基类的put()方法来设置键-值对 void load(InputStream inStream)//从输入流中读取属性列表（键和元素对）。通过对指定文件进行装载获取该文件中所有键-值对 void clear()//清除所装载的键-值对，该方法由基类Hashtable提供改良后的BaseDAO

public class BaseDao { //省略变量定义代码…… static{ init();} public static void init(){ Properties params=new Properties(); String configFile = "database.properties"; InputStream is=BaseDao.class.getClassLoader() .getResourceAsStream(configFile); try { params.load(is); } catch (IOException e) {//….} driver=params.getProperty("driver"); url=params.getProperty("url"); user=params.getProperty("user"); password=params.getProperty("password"); } //省略其他方法代码……} 使用实体类传递数据注意点

属性一般使用private修饰

提供public修饰的getter/setter方法

实体类提供无参构造方法，根据业务提供有参构造

实现java.io.Serializable接口，支持序列化机制

如果不实现这个接口，在某些数据持久框架下进行数据持久化会出现问题。hibernate就是这样的

代码实现

数据库模型

第一编写实体类

package kgc.pojo;

public class Grade {

private int GradeId;

private String gradeName;

@Override

public boolean equals(Object obj) {

return super.equals(obj);

}

@Override

public int hashCode() {

return super.hashCode();

}

public int getGradeId() {

return GradeId;

}

public void setGradeId(int gradeId) {

GradeId = gradeId;

}

public String getGradeName() {

return gradeName;

}

public void setGradeName(String gradeName) {

this.gradeName = gradeName;

}

public Grade(int gradeId, String gradeName) {

super();

GradeId = gradeId;

this.gradeName = gradeName;

}

public Grade() {

super();

}

@Override

public String toString() {

return "Grade [gradeId=" + this.GradeId + ", gradeName=" + this.gradeName + "]";

}

第二编写接口

开闭接口

package kgc.dao.inner;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

public interface IBaseDao {

Connection getOpen();

void getClose(Connection con,PreparedStatement ps,ResultSet rs);

}

增删改查接口

package kgc.dao.inner;

import java.util.List;

import kgc.pojo.Grade;

public interface IGradeDao {

boolean add(Grade g);

boolean delete(Grade g);

boolean renewal(Grade g);

Grade selectOne(int id);

List<Grade> selectAll();

}

第三编写实现类

package kgc.dao;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import kgc.dao.inner.IBaseDao;

public class BaseDao implements IBaseDao {

Connection connection = null;

@Override

public Connection getOpen() {

try {

Class.forName("com.mysql.jdbc.Driver");

String url = "jdbc:mysql://localhost:3306/kj15?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone = GMT";

connection = DriverManager.getConnection(url, "root", "123qwe");

} catch (Exception e) {

}

if (connection == null) {

throw new NullPointerException();

}

return this.connection;

}

@Override

public void getClose(Connection con, PreparedStatement ps, ResultSet rs) {

if (rs != null) {

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

if (ps != null) {

try {

ps.close();

} catch (SQLException e) {

e.printStackTrace();

}

if (con != null) {

try {

con.close();

} catch (SQLException e) {

e.printStackTrace();

}

package kgc.dao;

import java.awt.TexturePaint;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import kgc.dao.inner.IGradeDao;

import kgc.pojo.Grade;

@SuppressWarnings("all")

public class GradeDao extends BaseDao implements IGradeDao {

@Override

public boolean add(Grade g) {

Connection con = getOpen();

PreparedStatement ps=null;

try {

ps = con.prepareStatement("insert into Grade(gradeName) values(?)");

ps.setString(1, g.getGradeName());

int ee = ps.executeUpdate();

if (ee>0) {

return true;

}else {

return false;

}

} catch (SQLException e) {

e.printStackTrace();

}

getClose(con, ps, null);

return false;

}

@Override

public boolean delete(Grade g) {

Connection con = getOpen();

PreparedStatement ps=null;

try {

ps = con.prepareStatement("delete from grade where id=? ");

ps.setInt(1, g.getGradeId());

int ee = ps.executeUpdate();

if (ee>0) {

return true;

}else {

return false;

}

} catch (SQLException e) {

e.printStackTrace();

}

getClose(con, ps, null);

return false;

}

@Override

public boolean renewal(Grade g) {

Connection con = getOpen();

PreparedStatement ps=null;

try {

ps = con.prepareStatement("update grade set gradename=? where gradeid=? ");

ps.setString(1, g.getGradeName());

ps.setInt(2, g.getGradeId());

int ee = ps.executeUpdate();

if (ee>0) {

return true;

}else {

return false;

}

} catch (SQLException e) {

e.printStackTrace();

}

getClose(con, ps, null);

return false;

}

@Override

public Grade selectOne(int id) {

Connection con = getOpen();

PreparedStatement ps=null;

ResultSet ey=null;

try {

ps = con.prepareStatement("select * from grade where gradeid=? ");

ps.setInt(1, id);

ey = ps.executeQuery();

while (ey.next()) {

int int1 = ey.getInt(1);

String string = ey.getString(2);

Grade grade = new Grade(int1,string);

return grade;

}

} catch (SQLException e) {

e.printStackTrace();

}

getClose(con, ps, ey);

return null;

}

@Override

public List<Grade> selectAll() {

Connection con = getOpen();

PreparedStatement ps=null;

ResultSet rs=null;

ArrayList<Grade> List = new ArrayList<>();

try {

ps = con.prepareStatement("select * from grade ");

rs = ps.executeQuery();

while (rs.next()) {

int int1 = rs.getInt(1);

String string = rs.getString(2);

Grade grade = new Grade(int1,string);

List.add(grade);

}

return List;

} catch (SQLException e) {

e.printStackTrace();

}

getClose(con, null, null);

return List;

}

第5 测试

package kgc.demo;

import java.util.List;

import kgc.dao.GradeDao;

import kgc.pojo.Grade;

public class JdbcDemo {

public static void main(String[] args) {

Grade ge = new Grade(1, "我入土阶段");

boolean add = new GradeDao().add(ge);

System.out.println(add);

GradeDao gd = new GradeDao();

List<Grade> selectAll = gd.selectAll();

Grade grade = selectAll.get(selectAll.size() - 1);

boolean delete = gd.delete(grade);

System.out.println(delete);

GradeDao gd1 = new GradeDao();

List<Grade> selectAll1 = gd.selectAll();

Grade grade1 = selectAll1.get(selectAll.size() - 1);

grade1.setGradeName("升天阶段");

boolean renewal = gd1.renewal(grade1);

System.out.println(renewal);

GradeDao gd2 = new GradeDao();

Grade selectOne = gd2.selectOne(1);

System.out.println(selectOne);

GradeDao gd3 = new GradeDao();

List<Grade> selectAll11 = gd3.selectAll();

for (Grade grade11 : selectAll11) {

System.out.println(grade11);

}

JDBC成功连接数据库啦！！！

以上方法还能改进后续会补！！！！！！

宠物鼠怎么养才能养活,从新手到专家的全面攻略

外国美女恶搞荷兰猪，姿势让中国人大开眼界，不愧是资本国喂养的

热点分享

布偶猫吃什么对毛发好原来这些食物就可以

对于布偶猫这种长毛猫来说，一般情况下，布偶猫这样的长毛猫咪毛...

这九种宠物既新奇又独特，看完你爱上没有？

这九种宠物既新奇又独特，看完你爱上没有？小猫，小狗，仓鼠...

推荐分享

缅因猫能长多大一种体型较大的猫

缅因猫能长多大?缅因猫是很多人都喜欢的一个品种，尤其是广大的女...

警惕狗贩的骗人损招星期狗的症状特征

警惕狗贩的骗人损招染色：这一招最多的是用在斑点狗、蝴蝶犬...

热门点击排行

我的狗老公李淑敏33——如何打造与宠物相伴的幸福生活？

南京宠物粮食薄荷饼宠物食品包装机

分享分类导航

萌宠日常

宠物饲养指南

宠物营养食谱

JDBC连接 数据库

Java Database Connectivity

DAO模式(Data Access Object(数据存取对象) )

宠物鼠怎么养才能养活,从新手到专家的全面攻略

外国美女恶搞荷兰猪，姿势让中国人大开眼界，不愧是资本国喂养的

布偶猫吃什么对毛发好 原来这些食物就可以

这九种宠物既新奇又独特，看完你爱上没有？

缅因猫能长多大 一种体型较大的猫

警惕狗贩的骗人损招 星期狗的症状特征

JDBC连接数据库

布偶猫吃什么对毛发好原来这些食物就可以

缅因猫能长多大一种体型较大的猫

警惕狗贩的骗人损招星期狗的症状特征