Skip to content

Commit

Permalink
chore: update Hibernate sample code
Browse files Browse the repository at this point in the history
  • Loading branch information
karenc-bq committed Mar 16, 2023
1 parent c3e0043 commit 015c86d
Show file tree
Hide file tree
Showing 8 changed files with 54 additions and 248 deletions.
2 changes: 1 addition & 1 deletion examples/HibernateExample/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ dependencies {
implementation 'jakarta.persistence:jakarta.persistence-api:3.1.0'
runtimeOnly 'org.postgresql:postgresql:42.5.1'
runtimeOnly 'mysql:mysql-connector-java:8.0.30'
runtimeOnly project(':aws-advanced-jdbc-wrapper')
implementation project(':aws-advanced-jdbc-wrapper')
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.0'
testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.0'
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,68 +16,71 @@

package software.amazon;

import org.hibernate.Hibernate;
import jakarta.persistence.EntityManager;
import jakarta.persistence.EntityManagerFactory;
import jakarta.persistence.Persistence;
import org.hibernate.Hibernate;
import software.amazon.entity.Address;
import software.amazon.entity.User;

import java.sql.SQLException;

public class JpaExample {
private static EntityManagerFactory entityManagerFactory = null;

public static void main(String[] args) {
try {
Address address = new Address();
address.setTown("Orangeville");
address.setStreet("Faulkner");
address.setCountry("Canada");
address.setPostal("L1L2M2");
insertAddress(address);
User user = new User();
user.setFirst("Dave");
user.setLast("Cramer");
user.setAddress(address);
insertUser(user);
private static final EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("Atlas");

public static void main(String[] args) {
int i = 0;
try {
while (true) {
Address address = new Address();
address.setTown("Orangeville");
address.setStreet("Faulkner");
address.setCountry("Canada");
address.setPostal("L1L2M2");

insertAddress(address);

while (true) {
User user1 = getUser(user.getId());
}
} catch (Exception ex ){
// exception should be a TransactionStateUnknownException on failover
ex.printStackTrace();
}
User user = new User();
user.setFirst("First" + i);
user.setLast("Last" + i);
user.setAddress(address);
insertUser(user);

i++;
}
} catch (Exception ex) {
// Exception should be a FailoverSuccessSQLException if failover occurred.
// For more information regarding FailoverSuccessSQLException please visit the driver's documentation.
ex.printStackTrace();
}
private static void insertUser(User user) throws Exception {
try (EntityManager entityManager = openEntityManager()) {
entityManager.getTransaction().begin();
entityManager.persist(user);
entityManager.getTransaction().commit();
}
}

private static void insertUser(User user) {
try (EntityManager entityManager = openEntityManager()) {
entityManager.getTransaction().begin();
entityManager.persist(user);
entityManager.getTransaction().commit();
}
private static void insertAddress(Address address) throws Exception {
try (EntityManager entityManager = openEntityManager()) {
entityManager.getTransaction().begin();
entityManager.persist(address);
entityManager.getTransaction().commit();
}
}

private static void insertAddress(Address address) {
try (EntityManager entityManager = openEntityManager()) {
entityManager.getTransaction().begin();
entityManager.persist(address);
entityManager.getTransaction().commit();
}
private static User getUser(int id) throws SQLException {
try (EntityManager entityManager = openEntityManager()) {
}

User user = entityManager.find(User.class, id);
Hibernate.initialize(user);
private static User getUser(int id) {
try (EntityManager entityManager = openEntityManager()) {

return user;
}
}
User user = entityManager.find(User.class, id);
Hibernate.initialize(user);

private static EntityManager openEntityManager() {
if (entityManagerFactory == null) {
entityManagerFactory = Persistence.createEntityManagerFactory( "Atlas" );
}
return entityManagerFactory.createEntityManager();
return user;
}
}

private static EntityManager openEntityManager() {
return entityManagerFactory.createEntityManager();
}
}

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -9,13 +9,12 @@

<properties>

<property name="hibernate.dialect" value="software.amazon.utility.AuroraPostgreSQLDialect"/>
<property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQLDialect"/>
<property name="hibernate.connection.driver_class" value="software.amazon.jdbc.Driver"/>
<property name="hibernate.connection.url" value="jdbc:aws-wrapper:postgresql://hostname.amazonaws.com/hibernate_orm_test"/>
<property name="hibernate.connection.url" value="jdbc:aws-wrapper:postgresql://db.cluster-xyz.region.rds.amazonaws.com/hibernate_orm_test"/>
<property name="hibernate.connection.username" value="hibernate_orm_test"/>
<property name="hibernate.connection.password" value="hibernate_orm_test"/>
<property name="hibernate.connection.jdbcProtocol" value="jdbc:postgresql://"/>
<property name="hibernate.connection.wrapperPlugins" value="failover"/>

<property name="hibernate.connection.pool_size" value="5"/>

Expand Down

0 comments on commit 015c86d

Please sign in to comment.