English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Usando PostgreSQL em nosso programa Java Antes de começar a usar PostgreSQL em nosso programa Java, precisamos garantir que o PostgreSQL JDBC e o Java estejam configurados no computador. Você pode verificar Tutorial Java, para entender como instalar Java. Agora vamos verificar como configurar o driver postgresqljdbc.
Baixe a versão mais recente do postgresql a partir do endereço seguinte-(version).jdbc.jar postgresql-jdbc download.
adicionar o arquivo jar baixado postgresql-(VERSION).jar, ou você pode usá-lo com-A opção classpath pode ser usada junto com os exemplos a seguir.
A parte seguinte assume que você tem alguma compreensão do conceito javajdbc. Se não, é recomendável que você gaste meia hora estudando o tutorial JDBC para familiarizar-se com os conceitos explicados abaixo.
O seguinte código Java mostra como conectar a um banco de dados existente. Se o banco de dados não existir, ele será criado e, por fim, será retornado um objeto de banco de dados.
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");
}
}Antes de compilar e executar o programa acima, encontre o arquivo pg_hba.conf na pasta de instalação do PostgreSQL e crie um arquivo, adicionando as seguintes linhas:
# IPv4 conexões locais: host all all 127.0.0.1/32 md5
Se o servidor postgres não estiver em execução, você pode usar o seguinte comando para iniciá-lo/Reinicie o servidor postgres
Agora, vamos compilar e executar o programa acima para conectar ao testdb. Aqui, usamos postgres como ID de usuário 123Como senha para acessar o banco de dados. Você pode alterá-la conforme a configuração e as configurações do banco de dados. Supomos ainda que a versão atual do driver JDBC postgresql-9.2-1002.jdbc3.jar está disponível no caminho atual.
C:\JavaPostgresIntegration>javac PostgreSQLJDBC.java C:\JavaPostgresIntegration>java -cp c:\tools\postgresql-9.2-1002.jdbc3.jar;C:\JavaPostgresIntegration PostgresJDBC Banco de dados aberto com sucesso
O seguinte programa Java será usado para criar uma tabela no banco de dados aberto anteriormente. Certifique-se de que o banco de dados alvo não possui essa tabela.
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 = \ +
"(ID INT PRIMÁRIA CHAVE NOT NULL," +
"NOME TEXT NOT NULL, \ +
"IDADE INT NOT NULL, \ +
"ENDEREÇO CHAR(50), \ +
"SALÁRIO 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("Tabela criada com sucesso");
}
}Ao compilar e executar o programa, ele criará a tabela COMPANY no banco de dados testdb e mostrará as seguintes duas linhas-
Banco de dados aberto com sucesso Tabela criada com sucesso
O seguinte programa Java mostra como criar registros na tabela COMPANY criada no exemplo anterior-
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();
String sql = \
+ "VALORES ("1, \'Paul' 32, \'California' 20000,00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALORES ("2, \'Allen' 25, \'Texas' 15000,00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALORES ("3, \'Teddy' 23, \'Norway' 20000,00 ");";
stmt.executeUpdate(sql);
sql = \
+ "VALORES ("4, \'Mark' 25, \'Rich-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("Registros criados com sucesso");
}
}在编译和执行上述程序时，它将在 COMPANY 表中创建给定的记录，并显示以下两行-
Banco de dados aberto com sucesso 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("Operação realizada com sucesso");
}
}Quando o programa é compilado e executado, os seguintes resultados são gerados
Banco de dados aberto com sucesso ID = 1 NAME = Paul AGE = 32 ADDRESS = California SALARY = 20000.0 ID = 2 NAME = Allen AGE = 25 ADDRESS = Texas SALARY = 15000.0 ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norway SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 Operação realizada com sucesso
以下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("Operação realizada com sucesso");
}
}Quando o programa é compilado e executado, os seguintes resultados são gerados
Banco de dados aberto com sucesso ID = 2 NAME = Allen AGE = 25 ADDRESS = Texas SALARY = 15000.0 ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norway SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 ID = 1 NAME = Paul AGE = 32 ADDRESS = California SALARY = 25000.0 Operação realizada com sucesso
以下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("Operação realizada com sucesso");
}
}Quando o programa é compilado e executado, os seguintes resultados são gerados
Banco de dados aberto com sucesso ID = 3 NAME = Teddy AGE = 23 ADDRESS = Norway SALARY = 20000.0 ID = 4 NAME = Mark AGE = 25 ADDRESS = Rich-Mond SALARY = 65000.0 ID = 1 NAME = Paul AGE = 32 ADDRESS = California SALARY = 25000.0 Operação realizada com sucesso