Java连接PostgreSql数据库及基本使用方式
更新时间：2023年03月01日 11:01:37 作者：_码农耕地人
这篇文章主要介绍了Java连接PostgreSql数据库及基本使用方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
我是应用Java封装的思想将所有的方法封装到了一个类里。
一）准备工作
1.下载链接需要的jar包
选择最新版本即可。
2.下载之后添加到模块里
3.创建一个工具类Util
书写空参构造，用于对数据库的全部操作。
二）连接
所需内容：数据库名，端口号，数据库地址，数据库用户名，密码
public static Connection Connect(){
Connection c = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql://服务器地址，本机写127.0.0.1:服务器端口号，默认5432/链接的数据库名",
"数据库用户名", "数据库密码");
} catch (Exception e) {
e.printStackTrace();
System.err.println(e.getClass().getName()+": "+e.getMessage());
System.exit(0);
}
System.out.println("Opened database successfully");
return c; //记得返回一下这个对象，后面一直在用
}三）查询
普通版本查询：数据库有三个字段，时间time、地点location、温度temperature
public static void select() {
//与数据库建立链接
Connection c = Util.Connect();
Statement stmt = null;
try {
stmt = c.createStatement();
String sql = "SELECT* FROM tmps;";
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
Date date = rs.getDate(1);
String location = rs.getString("location");
float temperature = rs.getFloat("temperature");
System.out.println("date" + date);
System.out.println("location:" + location);
System.out.println("temperature:" + temperature);
}
//关流操作
rs.close();
stmt.close();
c.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}下图中这种方法属于进阶方法，只需要输入sql语句即可将任意表中的数据都按照map集合的方式返回
public static List<HashMap<String,Object>> Select(String sql){
//1、与数据库建立链接
Connection c = Util.Connect();
//2、创建操作对象
Statement stmt = null;
//3、创建返回最终查询的数据集合
List<HashMap<String ,Object>> list=new ArrayList<>();
try {
//2.1、初始化操作对象
stmt = c.createStatement();
//4、执行需要执行的sql语句
ResultSet rs = stmt.executeQuery(sql);
//3.1开始封装返回的对象
ResultSetMetaData metaData = rs.getMetaData();//获取全部列名
int columnCount = metaData.getColumnCount();//列的数量
//5、读取数据
while (rs.next()) {
HashMap<String,Object> map=new HashMap<>();
for (int i = 1; i <= columnCount; i++) {
//getColumnName获取列名
String name = metaData.getColumnName(i);
//获取对应的元素
Object object = rs.getObject(i);
map.put(name,object);
}
list.add(map);
}
//6、关流操作
rs.close();
stmt.close();
c.close();
} catch (SQLException throwable) {
throwable.printStackTrace();
}
return list;
}四）添加
返回值是bool类型，表示是否添加成功。
***需要比查询多添加一句***
connect.setAutoCommit(false);
public static Boolean Insert(String sql){
//1、与数据库建立链接
Connection connect = Util.Connect();
//2、创建操作对象
Statement stmt = null;
int count = 0;
try {
//2.1、初始化创建对象
stmt=connect.createStatement();
//3、添加特殊语句。
connect.setAutoCommit(false);//之前不用
//4、执行添加操作
count = stmt.executeUpdate(sql);
//5、关流
stmt.close();
connect.commit();
connect.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
return count!=0;
}五）删除数据
public void Delete(String sql) {
//1、链接数据库
Connection c = this.Connect();
Statement stmt = null;
try {
c.setAutoCommit(false);
stmt = c.createStatement();
stmt.executeUpdate(sql);
c.commit();
c.close()
stmt.close();
} catch (SQLException throwable) {
throwable.printStackTrace();
}
}六）封装之后的代码总和
封装类
package postSQL.Util;
import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
public class Util {
private final Connection connect;
private final String userName;
private final String passWord;
private final String ipAddress;
private final String databaseName;
private final String port;
//构造方法
public Util(String userName, String passWord, String ipAddress, String databaseName, String port) {
this.userName = userName;
this.passWord = passWord;
this.ipAddress = ipAddress;
this.databaseName = databaseName;
this.port = port;
this.connect = this.Connect();
}
//建立链接
private Connection Connect() {
Connection c = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql://" + this.ipAddress + ":" + this.port + "/" + this.databaseName,
this.userName, this.passWord);
} catch (Exception e) {
e.printStackTrace();
System.err.println(e.getClass().getName() + ": " + e.getMessage());
System.exit(0);
}
return c;
}
//关流操作
public void close() {
Connection c = this.connect;
try {
c.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
}
//查询
public List<HashMap<String, Object>> Select(String sql) {
//1、与数据库建立链接
Connection c = this.connect;
//2、创建操作对象
Statement stmt = null;
//3、创建返回最终查询的数据集合
List<HashMap<String, Object>> list = new ArrayList<>();
try {
//2.1、初始化操作对象
stmt = c.createStatement();
//4、执行需要执行的sql语句
ResultSet rs = stmt.executeQuery(sql);
//3.1开始封装返回的对象
ResultSetMetaData metaData = rs.getMetaData();//获取全部列名
int columnCount = metaData.getColumnCount();//列的数量
//5、读取数据
while (rs.next()) {
HashMap<String, Object> map = new HashMap<>();
for (int i = 1; i <= columnCount; i++) {
//getColumnName获取列名
String name = metaData.getColumnName(i);
//获取对应的元素
Object object = rs.getObject(i);
map.put(name, object);
}
list.add(map);
}
//6、关流操作
rs.close();
stmt.close();
//c.close();
} catch (SQLException throwable) {
throwable.printStackTrace();
}
return list;
}
//插入操作
public Boolean Insert(String sql) {
//1、与数据库建立链接
Connection connect = this.connect;
//2、创建操作对象
Statement stmt = null;
int count = 0;
try {
//2.1、初始化创建对象
stmt = connect.createStatement();
//3、添加特殊语句。
connect.setAutoCommit(false);//之前不用
//4、执行添加操作
count = stmt.executeUpdate(sql);
//5、关流
stmt.close();
connect.commit();
//connect.close();
} catch (SQLException throwables) {
throwables.printStackTrace();
}
return count != 0;
}
//删除
public void Delete(String sql) {
//1、链接数据库
Connection c = this.Connect();
Statement stmt = null;
try {
c.setAutoCommit(false);
stmt = c.createStatement();
stmt.executeUpdate(sql);
c.commit();
stmt.close();
} catch (SQLException throwable) {
throwable.printStackTrace();
}
}
}使用测试类
public static void main(String[] args) {
//构造方法
Util util=new Util("用户名","密码",
"ip地址","数据库名","端口号");
//插入语法
Boolean insert = util.Insert("insert into tmps (time,location,temperature)" +
" values('2022-1-1 16:00:00','场景八',112.3);"); //插入
//删除
util.Delete("delete from tmps t where t.location='场景七' ");
//查询
List<HashMap<String, Object>> select = util.Select("select * from tmps");
//关流
util.close();
System.out.println(select);
}总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家详细介绍了java设计模式之单例模式的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-11-11
这篇文章主要介绍了Mybatis的配置文件入门，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-07-07
这篇文章主要介绍了springboot的多种配置方式,本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-10-10
这篇文章主要给大家介绍了关于java中对象转json字符串的几种常用方式,在Java中可以使用许多库将对象转换为JSON字符串,其中最常用的是Jackson和Gson,文中通过代码介绍的非常详细,需要的朋友可以参考下2023-10-10
这篇文章主要为大家介绍了Spring @InitBinder注解使用及原理详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-03-03
java ArrayBlockingQueue阻塞队列的实现示例
ArrayBlockingQueue是一个基于数组实现的阻塞队列,本文就来介绍一下java ArrayBlockingQueue阻塞队列的实现示例,具有一定的参考价值,感兴趣的可以了解一下2024-02-02
Springboot实现人脸识别与WebSocket长连接的实现代码
这篇文章主要介绍了Springboot实现人脸识别与WebSocket长连接的实现,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧2023-11-11
本文主要介绍了Java批量获取地址间距离，获取两个地址间距离，实现方式比较多，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-07-07
Java正则校验密码至少包含字母数字特殊符号中的2种实例代码
正则表达式验证密码功能在项目中经常被使用到,但是很多朋友还是不大会使用密码正则表达式进行验证,下面这篇文章主要给大家介绍了关于Java正则校验密码至少包含字母数字特殊符号中2种的相关资料,需要的朋友可以参考下2022-08-08
这篇文章主要介绍了SpringBoot 微信退款功能的实现，本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-06-06
最新评论