Java链接PostgreSql数据库及基本使用

一准备工作

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);