English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Dans notre programme Java, nous commençons à utiliser PostgreSQL Avant de commencer à utiliser PostgreSQL dans notre programme Java, nous devons nous assurer que PostgreSQL JDBC et Java sont configurés sur l'ordinateur. Vous pouvez consulter Tutoriel JavaPour comprendre comment installer Java. Maintenant, examinons comment configurer le pilote postgresqljdbc.
Télécharger la dernière version de postgresql à partir de l'adresse suivante-(version).jdbc.jar postgresql-jdbc Télécharger.
Ajoutez le fichier jar téléchargé postgresql-(VERSION).jar, ou vous pouvez le lier avec-L'option classpath peut être utilisée conjointement, comme dans l'exemple suivant.
La partie suivante suppose que vous connaissez les concepts de javajdbc. Si ce n'est pas le cas, il est recommandé de passer une demi-heure à étudier le tutoriel JDBC pour vous familiariser avec les concepts expliqués ci-dessous.
Le code Java suivant montre comment se connecter à une base de données existante. Si la base de données n'existe pas, elle sera créée et finalement, un objet base de données sera retourné.
import java.sql.Connection;
import java.sql.DriverManager;
public class PostgreSQLJDBC {
public static void main(String args[]) {
Connection c = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"postgres", "123");
} catch (Exception e) {
e.printStackTrace();
System.err.println(e.getClass().getName())+: "+e.getMessage());
System.exit(0);
}
System.out.println("Opened database successfully");
}
}Avant de compiler et d'exécuter le programme ci-dessus, trouvez le fichier pg_hba.conf dans le répertoire d'installation de PostgreSQL et créez un fichier, puis ajoutez les lignes suivantes :
# IPv4 connections locales : host all tous tous 127.0.0.1/32 md5
Si le serveur postgres n'est pas en cours d'exécution, vous pouvez utiliser la commande suivante pour le démarrer/Redémarrez le serveur postgres :
Maintenant, compilons et exécutons le programme ci-dessus pour nous connecter à testdb. Ici, nous utilisons postgres comme identifiant utilisateur, 123Utilisez le mot de passe pour accéder à la base de données. Vous pouvez le modifier en fonction de la configuration et des paramètres de la base de données. Nous supposons également que la version actuelle du pilote JDBC postgresql-9.2-1002.jdbc3.jar est disponible dans le répertoire courant.
C:\JavaPostgresIntegration>javac PostgreSQLJDBC.java C:\\JavaPostgresIntegration>java -cp c:\\tools\\postgresql-9.2-1002.jdbc3.jar;C:\\JavaPostgresIntegration PostgresSQLJDBC Base de données ouverte avec succès
Le programme Java suivant sera utilisé pour créer une table dans la base de données ouverte précédemment. Assurez-vous qu'il n'existe pas déjà cette table dans la base de données cible.
import java.sql.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class PostgreSQLJDBC {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"manisha", "123");
System.out.println("Opened database successfully");
stmt = c.createStatement();
String sql = \ +
+
+
"AGE INT NOT NULL, \", +
"ADDRESS CHAR(\50), \", +
"SALARY REAL);"
stmt.executeUpdate(sql);
stmt.close();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName());+: "+ e.getMessage());
System.exit(0);
}
System.out.println("Table créée avec succès");
}
}Lors de la compilation et de l'exécution du programme, il créera la table COMPANY dans la base de données testdb et affichera les deux lignes suivantes-
Base de données ouverte avec succès Table créée avec succès
Le programme Java suivant montre comment créer des enregistrements dans la table COMPANY créée précédemment.-
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class PostgreSQLJDBC {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"manisha", "123");
c.setAutoCommit(false);
System.out.println("Opened database successfully");
stmt = c.createStatement();
+ "VALUES ("1 32 20000.00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALUES ("2 25 15000.00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALUES ("3 23, \'Norway\', 20000.00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALUES ("4, \'Mark\ 25-Mond ' 65000.00 ");";
stmt.executeUpdate(sql);
stmt.close();
c.commit();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName());+: "+ e.getMessage());
System.exit(0);
}
System.out.println("Enregistrements créés avec succès");
}
}在编译和执行上述程序时，它将在 COMPANY 表中创建给定的记录，并显示以下两行-
Base de données ouverte avec succès Records created successfully
以下Java程序展示了我们如何从上面示例中创建的COMPANY表中获取和显示记录
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class PostgreSQLJDBC {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"manisha", "123");
c.setAutoCommit(false);
System.out.println("Opened database successfully");
stmt = c.createStatement();
ResultSet rs = stmt.executeQuery("SELECT"} * FROM COMPANY; ");
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
String address = rs.getString("address");
float salary = rs.getFloat("salary");
System.out.println("ID = "); + id);
System.out.println("NAME = "); + name);
System.out.println("AGE = "); + age);
System.out.println("ADDRESS = "); + address);
System.out.println("SALARY = "); + salary);
System.out.println();
}
rs.close();
stmt.close();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName());+: "+ e.getMessage());
System.exit(0);
}
System.out.println("Opération effectuée avec succès");
}
}Lorsque le programme est compilé et exécuté, les résultats suivants sont générés
Base de données ouverte avec succès ID = 1 NAME = Paul AGE = 32 ADDRESS = Californie SALARY = 20000.0 ID = 2 NAME = Allen AGE = 25 ADDRESS = Texas SALARY = 15000.0 ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norvège SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 Opération effectuée avec succès
以下Java代码展示了如何使用UPDATE语句更新任何记录，然后从我们的COMPANY表中获取并显示更新后的记录
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class PostgreSQLJDBC {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"manisha", "123");
c.setAutoCommit(false);
System.out.println("Opened database successfully");
stmt = c.createStatement();
String sql = "UPDATE COMPANY set SALARY =" 25000.00 where ID=1;";
stmt.executeUpdate(sql);
c.commit();
ResultSet rs = stmt.executeQuery("SELECT"} * FROM COMPANY; ");
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
String address = rs.getString("address");
float salary = rs.getFloat("salary");
System.out.println("ID = "); + id);
System.out.println("NAME = "); + name);
System.out.println("AGE = "); + age);
System.out.println("ADDRESS = "); + address);
System.out.println("SALARY = "); + salary);
System.out.println();
}
rs.close();
stmt.close();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName());+: "+ e.getMessage());
System.exit(0);
}
System.out.println("Opération effectuée avec succès");
}
}Lorsque le programme est compilé et exécuté, les résultats suivants sont générés
Base de données ouverte avec succès ID = 2 NAME = Allen AGE = 25 ADDRESS = Texas SALARY = 15000.0 ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norvège SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 ID = 1 NAME = Paul AGE = 32 ADDRESS = Californie SALARY = 25000.0 Opération effectuée avec succès
以下Java代码展示了如何使用DELETE语句删除任何记录，然后从我们的COMPANY表中获取并显示剩余的记录
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class PostgreSQLJDBC6 {
public static void main(String args[]) {
Connection c = null;
Statement stmt = null;
try {
Class.forName("org.postgresql.Driver");
c = DriverManager
.getConnection("jdbc:postgresql:"//localhost:5432/testdb",
"manisha", "123");
c.setAutoCommit(false);
System.out.println("Opened database successfully");
stmt = c.createStatement();
String sql = "DELETE from COMPANY where ID =" 2;";
stmt.executeUpdate(sql);
c.commit();
ResultSet rs = stmt.executeQuery("SELECT"} * FROM COMPANY; ");
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
String address = rs.getString("address");
float salary = rs.getFloat("salary");
System.out.println("ID = "); + id);
System.out.println("NAME = "); + name);
System.out.println("AGE = "); + age);
System.out.println("ADDRESS = "); + address);
System.out.println("SALARY = "); + salary);
System.out.println();
}
rs.close();
stmt.close();
c.close();
} catch (Exception e) {
System.err.println(e.getClass().getName());+: "+ e.getMessage());
System.exit(0);
}
System.out.println("Opération effectuée avec succès");
}
}Lorsque le programme est compilé et exécuté, les résultats suivants sont générés
Base de données ouverte avec succès ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norvège SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 ID = 1 NAME = Paul AGE = 32 ADDRESS = Californie SALARY = 25000.0 Opération effectuée avec succès