• Java中使用JDBC操作Postgresql

    目录

    在Rocky Linux上安装postgresql

    用IntelliJ创建JavaFx项目

    画一个表格

     建立数据库访问

    在Rocky Linux上安装postgresql

    Rocky的仓库中自带了postgresql安装包，我们直接用dnf安装即可：

    dnf install postgresql-server -y

     安装好之后，先切换到postgres账户，进行初始化：

    1. su postgres
    2. initdb -D /var/lib/pgsql/data
    exit

    再启用并运行后台服务：

    systemctl enable postgresql

    systemctl start postgresql

    然后安装httpd:

    dnf install httpd -y

    然后安装PgAdmin，先更新仓库

    sudo rpm -i https://ftp.postgresql.org/pub/pgadmin/pgadmin4/yum/pgadmin4-redhat-repo-2-1.noarch.rpm

     然后开始安装：

    sudo yum install pgadmin4-web -y

    然后启动以下命令进行初始化设置：

    sudo /usr/pgadmin4/bin/setup-web.sh 

     启用并运行httpd：

    systemctl enable httpd

    systemctl start httpd

     排除防火墙：

    firewall-cmd --add-service http --permanent

    重新加载防火墙配置：

     firewall-cmd --reload

    重新启动httpd：

    systemctl restart httpd

    通过浏览器 打开pgadmin：

     输入之前初始化时填的账号密码进入系统，Server节点上右键：

     选择Register->Server：

     然后右击Database选择Create->Database：

     创建一个shop的库：

     创建表：

    1. CREATE TABLE public.product
    2. (
    3.     id uuid,
    4.     product_name character varying(100) NOT NULL,
    5.     amount integer NOT NULL,
    6.     unit_price double precision NOT NULL DEFAULT 0,
    7.     unit_name character varying(10) NOT NULL,
    8.     PRIMARY KEY (id)
    9. );
    10.  
    11. ALTER TABLE IF EXISTS public.product
    12.     OWNER to postgres;

    用IntelliJ创建JavaFx项目

    1. 创建Maven 项目

    选择 File -> New -> Project -> JavaFx ,填好后点击OK。

     2. 验证项目

    生成的pom文件：

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>com.examplegroupId>
    8.     <artifactId>demoartifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.     <name>demoname>
    11.  
    12.     <properties>
    13.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    14.         <junit.version>5.8.2junit.version>
    15.     properties>
    16.  
    17.     <dependencies>
    18.         <dependency>
    19.             <groupId>org.openjfxgroupId>
    20.             <artifactId>javafx-controlsartifactId>
    21.             <version>17.0.2version>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>org.openjfxgroupId>
    25.             <artifactId>javafx-fxmlartifactId>
    26.             <version>17.0.2version>
    27.         dependency>
    28.  
    29.         <dependency>
    30.             <groupId>org.junit.jupitergroupId>
    31.             <artifactId>junit-jupiter-apiartifactId>
    32.             <version>${junit.version}version>
    33.             <scope>testscope>
    34.         dependency>
    35.         <dependency>
    36.             <groupId>org.junit.jupitergroupId>
    37.             <artifactId>junit-jupiter-engineartifactId>
    38.             <version>${junit.version}version>
    39.             <scope>testscope>
    40.         dependency>
    41.     dependencies>
    42.  
    43.     <build>
    44.         <plugins>
    45.             <plugin>
    46.                 <groupId>org.apache.maven.pluginsgroupId>
    47.                 <artifactId>maven-compiler-pluginartifactId>
    48.                 <version>3.10.1version>
    49.                 <configuration>
    50.                     <source>17source>
    51.                     <target>17target>
    52.                 configuration>
    53.             plugin>
    54.             <plugin>
    55.                 <groupId>org.openjfxgroupId>
    56.                 <artifactId>javafx-maven-pluginartifactId>
    57.                 <version>0.0.8version>
    58.                 <executions>
    59.                     <execution>
    60.                         
    61.                         <id>default-cliid>
    62.                         <configuration>
    63.                             <mainClass>com.example.demo/com.example.demo.HelloApplicationmainClass>
    64.                             <launcher>applauncher>
    65.                             <jlinkZipName>appjlinkZipName>
    66.                             <jlinkImageName>appjlinkImageName>
    67.                             <noManPages>truenoManPages>
    68.                             <stripDebug>truestripDebug>
    69.                             <noHeaderFiles>truenoHeaderFiles>
    70.                         configuration>
    71.                     execution>
    72.                 executions>
    73.             plugin>
    74.         plugins>
    75.     build>
    76. project>

    3. 运行项目

    快捷键Atl+Shift+X，运行。

    画一个表格

    删掉自动生成的代码，新建Product.java

    注意：需要安装lombok插件。

    1. package org.example;
    2.  
    3. import lombok.Data;
    4.  
    5. @Data
    6. public class Product {
    7.     private String productName;
    8.     private Double price;
    9.     private Integer amount;
    10.     private String unitName;
    11. }

    新增Main.java

    1. package org.example;
    2.  
    3. import javafx.application.Application;
    4. import javafx.collections.FXCollections;
    5. import javafx.collections.ObservableList;
    6. import javafx.fxml.FXMLLoader;
    7. import javafx.scene.Parent;
    8. import javafx.scene.Scene;
    9. import javafx.scene.control.Button;
    10. import javafx.scene.control.TableColumn;
    11. import javafx.scene.control.TableView;
    12. import javafx.scene.control.cell.PropertyValueFactory;
    13. import javafx.scene.layout.GridPane;
    14. import javafx.scene.layout.HBox;
    15. import javafx.scene.layout.VBox;
    16. import javafx.stage.Stage;
    17.  
    18. import java.util.ArrayList;
    19. import java.util.List;
    20.  
    21. public class Main extends Application {
    22. 	public static void main(String[] args) {
    23. 		launch(args);
    24. 	}
    25.  
    26. 	@Override
    27. 	public void start(Stage stage) throws Exception {
    28. 		VBox root = new VBox();
    29. 		Scene scene = new Scene(root, 800, 600);
    30.  
    31. 		var table = createTable();
    32. 		root.getChildren().add(table);
    33. 		ObservableList products = FXCollections.observableArrayList(queryProducts());
    34. 		table.setItems(products);
    35.  
    36. 		HBox buttons = new HBox();
    37. 		root.getChildren().add(buttons);
    38. 		Button addButton = new Button("Add");
    39. 		buttons.getChildren().add(addButton);
    40. 		Button delButton = new Button("Delete");
    41. 		buttons.getChildren().add(delButton);
    42. 		stage.setTitle("JAVA商店");
    43. 		stage.setScene(scene);
    44. 		stage.show();
    45. 	}
    46.  
    47. 	private List queryProducts() {
    48. 		List list = new ArrayList<>();
    49. 		Product p = new Product();
    50. 		p.setProductName("电脑");
    51. 		p.setAmount(10);
    52. 		p.setPrice(3500.0);
    53. 		p.setUnitName("台");
    54. 		list.add(p);
    55. 		
    56. 		p = new Product();
    57. 		p.setProductName("石油");
    58. 		p.setAmount(10);
    59. 		p.setPrice(700.0);
    60. 		p.setUnitName("桶");
    61. 		list.add(p);
    62. 		return list;
    63. 	}
    64.  
    65. 	private TableView createTable() {
    66. 		TableView tableView = new TableView<>();
    67. 		var col = new TableColumn("名称");
    68. 		col.setCellValueFactory(new PropertyValueFactory("productName"));
    69. 		tableView.getColumns().add(col);
    70.  
    71. 		var col1 = new TableColumn("数量");
    72. 		col1.setCellValueFactory(new PropertyValueFactory("amount"));
    73. 		tableView.getColumns().add(col1);
    74. 		var col2 = new TableColumn("单价");
    75. 		col2.setCellValueFactory(new PropertyValueFactory<>("price"));
    76. 		tableView.getColumns().add(col2);
    77. 		var col3 = new TableColumn("单位");
    78. 		col3.setCellValueFactory(new PropertyValueFactory<>("unitName"));
    79. 		tableView.getColumns().add(col3);
    80. 		return tableView;
    81. 	}
    82. }

    修改pom文件

    1. <project xmlns="http://maven.apache.org/POM/4.0.0"
    2. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3. 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4. 	<modelVersion>4.0.0modelVersion>
    5. 	<parent>
    6. 		<groupId>java-demogroupId>
    7. 		<artifactId>rootartifactId>
    8. 		<version>0.0.1-SNAPSHOTversion>
    9. 	parent>
    10. 	<artifactId>jdbcartifactId>
    11. 	<dependencies>
    12. 		<dependency>
    13. 			<groupId>org.openjfxgroupId>
    14. 			<artifactId>javafx-baseartifactId>
    15. 			<version>19version>
    16. 		dependency>
    17.  
    18. 		<dependency>
    19. 			<groupId>org.openjfxgroupId>
    20. 			<artifactId>javafx-controlsartifactId>
    21. 			<version>19version>
    22. 		dependency>
    23. 		<dependency>
    24. 			<groupId>org.openjfxgroupId>
    25. 			<artifactId>javafx-graphicsartifactId>
    26. 			<version>19version>
    27. 		dependency>
    28. 		<dependency>
    29. 			<groupId>org.openjfxgroupId>
    30. 			<artifactId>javafx-fxmlartifactId>
    31. 			<version>19version>
    32. 		dependency>
    33. 		<dependency>
    34. 			<groupId>org.openjfxgroupId>
    35. 			<artifactId>javafx-mediaartifactId>
    36. 			<version>19version>
    37. 		dependency>
    38.  
    39. 	dependencies>
    40. 	<build>
    41. 		<plugins>
    42. 			<plugin>
    43. 				<groupId>org.openjfxgroupId>
    44. 				<artifactId>javafx-maven-pluginartifactId>
    45. 				<version>0.0.8version>
    46. 				<configuration>
    47. 					<mainClass>org.example.MainmainClass>
    48. 				configuration>
    49. 			plugin>
    50. 		plugins>
    51. 	build>
    52. project>

    运行结果：

     建立数据库访问

    修改pom.xml添加postgresql的驱动：

    1. <dependency>
    2.     <groupId>org.postgresqlgroupId>
    3.     <artifactId>postgresqlartifactId>
    4.     <version>42.5.1version>
    5. dependency>

    修改Main.java，连接数据库：

    JDBC4.0之后DriverManager会自动搜索classpath中的驱动类，所以不需要Class.forName('driverClass')的方式加载驱动类。

    1.     private Connection getConnection() throws SQLException {
    2.         Connection conn = null;
    3.         Properties connectionProps = new Properties();
    4.         connectionProps.put("user", "postgres");
    5.         connectionProps.put("password", "postgres");
    6.         conn = DriverManager.getConnection(
    7.                 "jdbc:postgresql://192.168.0.128/shop",
    8.                 connectionProps);
    9.  
    10.         return conn;
    11.     }

    连接到数据库之后，就可以增删改查操作了。为了防止SQL注入，通常查询字符串使用参数化方式，待输入值在查询语句使用“?”代替。

    新增：

    1. try {
    2.                 Connection conn = getConnection();
    3.                 String query = "INSERT INTO product(\n" +
    4.                         "\tid, product_name, amount, unit_price, unit_name)\n" +
    5.                         "\tVALUES (?, ?, ?, ?, ?);";
    6.                 try (PreparedStatement stmt = conn.prepareStatement(query)) {
    7.                     stmt.setObject(1, UUID.randomUUID());
    8.                     stmt.setString(2, pn.getText());
    9.                     stmt.setInt(3, Integer.valueOf(amountField.getText()));
    10.                     stmt.setDouble(4, Double.valueOf(priceField.getText()));
    11.                     stmt.setString(5, unitField.getText());
    12.                     stmt.executeUpdate();
    13.                 }
    14.                 conn.close();

    最终效果

     

  • 相关阅读:
    毕设 JAVA JSP餐饮管理程序论文
    泡泡玛特城市乐园开园在即，知名潮玩IP落地北京朝阳
    Python推导式
    Mybatis的使用（4）
    Hive insert插入数据与with子查询
    S3 对象重命名
    mongoose 源码解读（一）
    数据结构与算法----详解二叉树的遍历(迭代、递归)
    SpringBoot 如何使用 CORS 进行跨域资源共享
    JavaScript 编写排序算法：冒泡排序、选择排序、插入排序
  • 原文地址：https://blog.csdn.net/icoolno1/article/details/108229507