微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

javax.persistence.Persistence的实例源码

项目:java-jdbc    文件HibernateTest.java   
@Test
public void jpa() {
  EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory("jpa");

  Employee employee = new Employee();
  EntityManager entityManager = entityManagerFactory.createEntityManager();
  entityManager.getTransaction().begin();
  entityManager.persist(employee);
  entityManager.getTransaction().commit();
  entityManager.close();
  entityManagerFactory.close();

  assertNotNull(employee.id);

  List<MockSpan> finishedSpans = mockTracer.finishedSpans();
  assertEquals(8,finishedSpans.size());

  checkSpans(finishedSpans);
  assertNull(mockTracer.activeSpan());
}
项目:bibliometrics    文件RolePermissionDAO.java   
/**
 * retrieves the <code>RolesPermission</code> by the role.
 * 
 * @param role
 *            the role
 * @return userPermissions the list of permissions of the user
 * 
 */
public static Set<String> getPermission(String role) {
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("userData");
    EntityManager em = emf.createEntityManager();
    EntityTransaction tx = em.getTransaction();
    tx.begin();
    CriteriaBuilder cb = em.getCriteriaBuilder();
    CriteriaQuery<RolePermission> q = cb.createquery(RolePermission.class);
    Root<RolePermission> c = q.from(RolePermission.class);
    q.select(c).where(cb.equal(c.get("roleName"),role));
    TypedQuery<RolePermission> query = em.createquery(q);
    List<RolePermission> permissions = query.getResultList();
    Set<String> userPermissions = new HashSet<String>();
    for (RolePermission permission : permissions)
        userPermissions.add(permission.getPermission());
    tx.commit();
    em.close();
    return userPermissions;
}
项目:BecomeJavaHero    文件App8.java   
public static void main(String[] args) {
    EntityManagerFactory entityManagerFactory = Persistence
            .createEntityManagerFactory("pl.edu.bogdan.training.db.entity");
    EntityManager em = entityManagerFactory.createEntityManager();

    em.getTransaction().begin();

    CriteriaBuilder cb = em.getCriteriaBuilder();
    CriteriaQuery<User> cq = cb.createquery(User.class);
    Root<User> from = cq.from(User.class);
    Join<User,Role> join = from.join("role",JoinType.LEFT);
    cq.where(cb.equal(join.get("name"),"ordinary"));
    TypedQuery<User> tq = em.createquery(cq);
    List<User> users = tq.getResultList();
    for (User u : users) {
        System.out.println(u.getLastName());
    }

    em.getTransaction().commit();
    em.close();
    entityManagerFactory.close();
}
项目:bibliometrics    文件UserDAO.java   
public static User getUser(String username) {
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("userData");
    EntityManager em = emf.createEntityManager();
    EntityTransaction tx = em.getTransaction();
    tx.begin();
    CriteriaBuilder cb = em.getCriteriaBuilder();
    CriteriaQuery<User> q = cb.createquery(User.class);
    Root<User> c = q.from(User.class);
    q.select(c).where(cb.equal(c.get("username"),username));
    TypedQuery<User> query = em.createquery(q);
    List<User> users = query.getResultList();
    em.close();
    LOGGER.info("found " + users.size() + " users with username " + username);
    if (users.size() == 1)
        return users.get(0);
    else
        return null;
}
项目:java-p6spy    文件HibernateTest.java   
@Test
public void jpaWithActiveSpanOnlyWithParent() {
  try (Scope activeSpan = mockTracer.buildSpan("parent").startActive(true)) {
    EntityManagerFactory entityManagerFactory =
        Persistence.createEntityManagerFactory("jpa_active_span_only");

    Employee employee = new Employee();
    EntityManager entityManager = entityManagerFactory.createEntityManager();
    entityManager.getTransaction().begin();
    entityManager.persist(employee);
    entityManager.getTransaction().commit();
    entityManager.close();
    entityManagerFactory.close();

    assertNotNull(employee.id);
  }

  List<MockSpan> finishedSpans = mockTracer.finishedSpans();
  assertEquals(9,finishedSpans.size());
  checkSameTrace(finishedSpans);
  assertNull(mockTracer.scopeManager().active());
}
项目:marathonv5    文件DataAppLoader.java   
/**
 * @param args the command line arguments
 */
@PersistenceUnit
public static void main(String[] args) {
    System.out.println("Creating entity @R_410_4045@ion...");
    EntityManager entityManager = Persistence.createEntityManagerFactory("DataAppLibraryPULocal").createEntityManager();
    EntityTransaction et = entityManager.getTransaction();
    et.begin();
    loaddiscountRate(entityManager);
    loadRegion(entityManager);
    loadRole(entityManager);
    loadTransmission(entityManager);
    loadProductType(entityManager);
    loadEngine(entityManager);
    loadProduct(entityManager);
    et.commit();


    EntityManager specialEntityManager = new InitialLoadEntityManagerProxy(entityManager);
    SalesSimulator simulator = new SalesSimulator(specialEntityManager);
    Calendar cal = Calendar.getInstance();
    int year = cal.get(Calendar.YEAR);
    cal.clear();
    cal.set(year-1,1,0); // go back to begining of year,3 years ago
    System.out.println("Creating historical data...");
    System.out.println("        This may take 5 to 15min depending on machine speed.");
    simulator.run(cal.getTime(),new Date());

    entityManager.close();
}
项目:sumo    文件PreferencesDialog.java   
/** Creates new form PreferencesDialog */
public PreferencesDialog() {
    initComponents();
    emf = Persistence.createEntityManagerFactory("GeoImageViewerPU");
    EntityManager em = emf.createEntityManager();
    Query q = em.createNamedQuery("Preferences.findAll");
    prefs = q.getResultList();
    em.close();

    setTitle("SUMO Preferences");
    initTable();
}
项目:sumo    文件PluginsManager.java   
public PluginsManager() {
    plugins = new HashMap<String,Plugins>();
    actions = new HashMap<String,ISumoAction>();

       emf = Persistence.createEntityManagerFactory("GeoImageViewerPU");

       EntityManager em = emf.createEntityManager();
       em.getTransaction().begin();
       Query q = em.createquery("select p.className from Plugins p");
       List<String> dbPuginNames = q.getResultList();
       em.getTransaction().commit();
       populateDatabase(dbPuginNames);

       em.getTransaction().begin();

       Query q2 = em.createquery("select p from Plugins p");
       List<Plugins> dbPlugins = q2.getResultList();
       dbPlugins = q2.getResultList();
       em.getTransaction().commit();

       em.close();
       List<ISumoAction> landActions=getDynamicActionForLandmask();
       parseActions(dbPlugins);

       parseActionsLandMask(landActions);
}
项目:coodoo-listing    文件AbstractDbUnitTest.java   
/**
 * Set up memory database and insert data from test-dataset.xml
 * 
 * @throws DatabaseUnitException
 * @throws HibernateException
 * @throws sqlException
 */
@BeforeClass
public static void initEntityManager() throws HibernateException,DatabaseUnitException,sqlException {
    entityManagerFactory = Persistence.createEntityManagerFactory("listing-test-db");
    entityManager = entityManagerFactory.createEntityManager();
    connection = new DatabaseConnection(((SessionImpl) (entityManager.getDelegate())).connection());
    connection.getConfig().setProperty(DatabaseConfig.PROPERTY_DATATYPE_FACTORY,new HsqldbDataTypeFactory());

    InputStream inputStream = Thread.currentThread().getContextClassLoader().getResourceAsstream(datasetXml);
    if (inputStream != null) {
        FlatXmlDataSetBuilder flatXmlDataSetBuilder = new FlatXmlDataSetBuilder();
        flatXmlDataSetBuilder.setColumnSensing(true);
        dataset = flatXmlDataSetBuilder.build(inputStream);
        DatabaSEOperation.CLEAN_INSERT.execute(connection,dataset);
    }
}
项目:chr-krenn-fhj-ws2017-sd17-pse    文件AbstractDAOTest.java   
@BeforeClass
public static void connect() throws DatabaseException {
    factory = Persistence.createEntityManagerFactory(persistencUnitName);
    assertNotNull(factory);
    em = factory.createEntityManager();
    assertNotNull(em);
    tx = em.getTransaction();
    assertNotNull(tx);

       edao.setEntityManager(em);
    tx.begin();
    for (int i = 1; i <= 7; i++) { 
        if (edao.findById(i) == null)
            edao.createEnumeration(i);
    }
    tx.commit();

}
项目:bibliometrics    文件UserRoleDAO.java   
/**
 * retrieves the list of roles for a given username.
 * 
 * @param username
 *            the username
 * @return userRoles the roles
 * 
 */
public static Set<String> getRoles(String username) {
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("userData");
    EntityManager em = emf.createEntityManager();
    CriteriaBuilder cb = em.getCriteriaBuilder();
    CriteriaQuery<UserRole> q = cb.createquery(UserRole.class);
    Root<UserRole> c = q.from(UserRole.class);
    q.select(c).where(cb.equal(c.get("username"),username));
    TypedQuery<UserRole> query = em.createquery(q);
    List<UserRole> roles = query.getResultList();
    Set<String> userRoles = new HashSet<String>();
    em.close();
    for (UserRole role : roles)
        userRoles.add(role.getRoleName());
    return userRoles;
}
项目:esup-ecandidat    文件SiScolApogeeWSServiceImpl.java   
/**
 * @see fr.univlorraine.ecandidat.services.siscol.SiScolGenericService#getVersion()
 */
@Override
public Version getVersion() throws SiScolException {
    try {
        EntityManagerFactory emf = Persistence.createEntityManagerFactory("pun-jpa-siscol");
        EntityManager em = emf.createEntityManager();
        Query query = em.createquery("Select a from VersionApo a where a.datCre is not null order by a.datCre desc",VersionApo.class).setMaxResults(1);
        List<VersionApo> listeVersionApo = query.getResultList();
        em.close();
        if (listeVersionApo != null && listeVersionApo.size() > 0) {
            VersionApo versionApo = listeVersionApo.get(0);
            return new Version(versionApo.getId().getCodVer());
        } else {
            return null;
        }
    } catch (Exception e) {
        throw new SiScolException("SiScol database error on getVersion",e.getCause());
    }
}
项目:java-jdbc    文件HibernateTest.java   
@Test
public void jpa_with_active_span_only() {
  EntityManagerFactory entityManagerFactory = Persistence
      .createEntityManagerFactory("jpa_active_span_only");

  Employee employee = new Employee();
  EntityManager entityManager = entityManagerFactory.createEntityManager();
  entityManager.getTransaction().begin();
  entityManager.persist(employee);
  entityManager.getTransaction().commit();
  entityManager.close();
  entityManagerFactory.close();

  assertNotNull(employee.id);

  List<MockSpan> finishedSpans = mockTracer.finishedSpans();
  assertEquals(0,finishedSpans.size());

  assertNull(mockTracer.activeSpan());
}
项目:esup-ecandidat    文件SiScolApogeeWSServiceImpl.java   
/**
 * Renvoie les voeux OPI d'un individu
 * 
 * @param indOpi
 * @return
 * @throws SiScolException
 */
private List<VoeuxIns> getVoeuxApogee(IndOpi indOpi) throws SiScolException {
    try {
        String queryString = "Select a from VoeuxIns a where a.id.codindOpi = " + indOpi.getCodindOpi();
        logger.debug("Vérification des voeux " + queryString);
        EntityManagerFactory emf = Persistence.createEntityManagerFactory("pun-jpa-siscol");
        EntityManager em = emf.createEntityManager();
        Query query = em.createquery(queryString,VoeuxIns.class);
        List<VoeuxIns> listeSiScol = query.getResultList();
        em.close();
        return listeSiScol;
    } catch (Exception e) {
        throw new SiScolException("SiScol database error on getVoeuxApogee",e);
    }

}
项目:osc-core    文件InMemDB.java   
static EntityManagerFactory init() {

        try {
            Map<String,Object> props = new HashMap<>();

            props.put("javax.persistence.jdbc.driver","org.h2.Driver");
            props.put("javax.persistence.jdbc.url","jdbc:h2:mem:test"); // in-memory db
            props.put("javax.persistence.schema-generation.database.action","drop-and-create"); // create brand-new db schema in memory
            props.put("hibernate.dialect","org.hibernate.dialect.H2Dialect");
            props.put("hibernate.show_sql","false"); // Set this to true to debug any DB failures
            props.put("hibernate.hbm2ddl.halt_on_error",Boolean.TRUE); // Cause test to fail in case of any errors during db creation


            emf = Persistence.createEntityManagerFactory("osc-server",props);

            return emf;

        } catch (Throwable ex) {
            System.out.println("Initial SessionFactory creation Failed." + ex);
            throw new ExceptionInInitializerError(ex);
        }
    }
项目:cloud-employeeslistapp    文件JpaEntityManagerFactory.java   
/**
 * Returns the singleton EntityManagerFactory instance for accessing the
 * default database.
 * 
 * @return the singleton EntityManagerFactory instance
 * @throws NamingException
 *             if a naming exception occurs during initialization
 * @throws sqlException
 *             if a database occurs during initialization
 * @throws IOException 
 */
public static synchronized EntityManagerFactory getEntityManagerFactory()
        throws NamingException,sqlException,IOException {
    if (entityManagerFactory == null) {
        InitialContext ctx = new InitialContext();
        BasicDataSource ds = new BasicDataSource();
        JsonNode credentials = readCredentialsFromEnvironment();
        ds.setDriverClassName(credentials.get("driver").asText());
        ds.setUrl(credentials.get("url").asText());
        ds.setUsername(credentials.get("user").asText());
        ds.setPassword(credentials.get("password").asText());
        Map<String,Object> properties = new HashMap<String,Object>();
        properties.put(PersistenceUnitProperties.NON_JTA_DATASOURCE,ds);
        entityManagerFactory = Persistence.createEntityManagerFactory(
                PERSISTENCE_UNIT_NAME,properties);
    }
    return entityManagerFactory;
}
项目:java-jdbc    文件HibernateTest.java   
@Test
public void jpa_with_parent_and_active_span_only() {

  try (Scope ignored = mockTracer.buildSpan("parent").startActive(true)) {
    EntityManagerFactory entityManagerFactory = Persistence
        .createEntityManagerFactory("jpa_active_span_only");

    EntityManager entityManager = entityManagerFactory.createEntityManager();

    entityManager.getTransaction().begin();
    entityManager.persist(new Employee());
    entityManager.persist(new Employee());
    entityManager.getTransaction().commit();
    entityManager.close();
    entityManagerFactory.close();
  }

  List<MockSpan> spans = mockTracer.finishedSpans();
  assertEquals(11,spans.size());
  checkSameTrace(spans);
  assertNull(mockTracer.activeSpan());
}
项目:testing_security_development_enterprise_systems    文件QuizEntityTest.java   
@Test
public void testQuiz(){

    Quiz quiz = new Quiz();
    quiz.setQuestion("Will this test pass?");
    quiz.setFirstAnswer("Yes");
    quiz.setSecondAnswer("No");
    quiz.setThirdAnswer("Maybe");
    quiz.setFourthAnswer("No idea");
    quiz.setIndexOfCorrectAnswer(0);

    EntityManagerFactory factory = Persistence.createEntityManagerFactory("DB");
    EntityManager em = factory.createEntityManager();

    EntityTransaction tx = em.getTransaction();
    tx.begin();

    em.persist(quiz);

    tx.commit();
}
项目:strix    文件StrixManager.java   
/**
 * Opens an {@link EntityManagerFactory} for the provided {@code persistenceUnit} if not already opened/cached.
 *
 * @param persistenceUnit The name of the persistence unit
 * @return The {@link EntityManagerFactory} for {@code persistenceUnit}
 */
private static synchronized EntityManagerFactory getEntityManagerFactory(String persistenceUnit) {
    if (persistenceUnit.isEmpty() && DEFAULT_PERSISTENCE_UNIT != null) {
        persistenceUnit = DEFAULT_PERSISTENCE_UNIT;
    }
    if (!SESSION_FACTORY_STORE.containsKey(persistenceUnit)) {
        LOG.debug("Create new EntityManagerFactory for persistence unit {}",persistenceUnit);
        SESSION_FACTORY_STORE.put(
              persistenceUnit,Persistence.createEntityManagerFactory(
                    persistenceUnit.isEmpty() ? null : persistenceUnit,PERSISTENCE_PROPERTIES.get(persistenceUnit)
              )
        );
    }
    return SESSION_FACTORY_STORE.get(persistenceUnit);
}
项目:Java_Swing_Programming    文件Soru1.java   
private void btn_kontrolActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_kontrolActionPerformed
    // Todo add your handling code here:
     EntityManagerFactory emf = Persistence.createEntityManagerFactory("BP2_LAB2PU");
        EntityManager em = emf.createEntityManager();
        Query q = em.createquery("SELECT m FROM Musteri m");
        List<Musteri> musteriler = q.getResultList();

    for (Musteri musteri : musteriler) {
         Path p= Paths.get("musteriler\\"+musteri.getId()+".txt");
         try {
             p.toRealPath();
         } catch (IOException ex) {
             System.out.println(musteri.getId()+" numaralı müsteri dosyası bulunamadı");
         }
    }

}
项目:lams    文件LocalEntityManagerfactorybean.java   
/**
 * Initialize the EntityManagerFactory for the given configuration.
 * @throws javax.persistence.PersistenceException in case of JPA initialization errors
 */
@Override
protected EntityManagerFactory createNativeEntityManagerFactory() throws PersistenceException {
    if (logger.isInfoEnabled()) {
        logger.info("Building JPA EntityManagerFactory for persistence unit '" + getPersistenceUnitName() + "'");
    }
    PersistenceProvider provider = getPersistenceProvider();
    if (provider != null) {
        // Create EntityManagerFactory directly through PersistenceProvider.
        EntityManagerFactory emf = provider.createEntityManagerFactory(getPersistenceUnitName(),getJpaPropertyMap());
        if (emf == null) {
            throw new IllegalStateException(
                    "PersistenceProvider [" + provider + "] did not return an EntityManagerFactory for name '" +
                    getPersistenceUnitName() + "'");
        }
        return emf;
    }
    else {
        // Let JPA perform its standard PersistenceProvider autodetection.
        return Persistence.createEntityManagerFactory(getPersistenceUnitName(),getJpaPropertyMap());
    }
}
项目:Java_Swing_Programming    文件Frm_KullaniciSayfasi.java   
private void btn_kabuletActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_kabuletActionPerformed

// Todo add your handling code here:
        if (tbl_arkadaslistesi.getSelectedRow() < 0) {
            JOptionPane.showMessageDialog(rootPane,"Bir kullanıcı Seçmelisiniz");
            return;
        }

        int id = (int) dtm2.getValueAt(tbl_arkadaslistesi.getSelectedRow(),0);

        EntityManagerFactory emf = Persistence.createEntityManagerFactory("SosyalMedyaAppWithDatabasePU");
        EntityManager em = emf.createEntityManager();

        Query q = em.createquery("UPDATE ARKADASLIK u SET u.kabulDurumu=true  WHERE u.idUserKabul=:kabulid AND U.idUserIstek=:istekid");
        q.setParameter("istekid",id);
        q.setParameter("kabulid",Frm_Login.loginuser.getId());

        em.getTransaction().begin();
        q.executeUpdate();
        em.getTransaction().commit();


    }
项目:Java_Swing_Programming    文件Frm_KullaniciSayfasi.java   
private void btn_silActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_silActionPerformed
    // Todo add your handling code here:
    if (tbl_arkadaslistesi.getSelectedRow() < 0) {
        JOptionPane.showMessageDialog(rootPane,"Bir kullanıcı Seçmelisiniz");
        return;
    }

    int id = (int) dtm2.getValueAt(tbl_arkadaslistesi.getSelectedRow(),0);

    EntityManagerFactory emf = Persistence.createEntityManagerFactory("SosyalMedyaAppWithDatabasePU");
    EntityManager em = emf.createEntityManager();

    Query q = em.createquery("DELETE FROM ARKADASLIK u WHERE u.idUserKabul=:kabulid AND U.idUserIstek=:istekid");
    q.setParameter("istekid",id);
    q.setParameter("kabulid",Frm_Login.loginuser.getId());

    em.getTransaction().begin();
    q.executeUpdate();
    em.getTransaction().commit();


}
项目:Java_Swing_Programming    文件Soru1.java   
public Soru1() {
    initComponents();

    ///SORGULAMA
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("BP2_LAB2PU");
    EntityManager em = emf.createEntityManager();

    Query q = em.createquery("SELECT d FROM Doktor d");
    doktorlar = q.getResultList();
    for (Doktor dr : doktorlar) {
        cmb_doktorlar.addItem(dr.getAdi() + " " + dr.getSoyadi());
    }

    dtm = new DefaultTableModel();
    dtm.setColumnIdentifiers(new Object[]{"ID","ADI","SoyaDI","DOkTOR ID"});
    q = em.createquery("SELECT h FROM Hasta h");
    List<Hasta> hastalar = q.getResultList();
    for (Hasta hs : hastalar) {
        dtm.addRow(new Object[]{hs.getId(),hs.getAdi(),hs.getSoyadi(),hs.getIdDoktor()});
    }
    tbl_hastalar.setModel(dtm);
    /////
}
项目:Java_Swing_Programming    文件Soru1.java   
private void btn_hastaekleActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_hastaekleActionPerformed
    // Todo add your handling code here:
    Hasta newhasta = new Hasta();
    newhasta.setId(Integer.parseInt(txt_hastaid.getText()));
    newhasta.setAdi(txt_hastaadi.getText());
    newhasta.setSoyadi(txt_hastaadi.getText());
    newhasta.setIdDoktor(doktorlar.get(cmb_doktorlar.getSelectedindex()).getId());
    ///EKLEME
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("BP2_LAB2PU");
    EntityManager em = emf.createEntityManager();
    em.getTransaction().begin();
    em.persist(newhasta);
    em.getTransaction().commit();

    dtm.setRowCount(0);
    Query q = em.createquery("SELECT h FROM Hasta h");
    List<Hasta> hastalar = q.getResultList();
    for (Hasta hs : hastalar) {
        dtm.addRow(new Object[]{hs.getId(),hs.getIdDoktor()});
    }
    tbl_hastalar.setModel(dtm);

    /////

}
项目:Java_Swing_Programming    文件Soru1.java   
private void btn_degistirActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_degistirActionPerformed
    // Todo add your handling code here:
       // UPDATE
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("BP2_LAB2PU");
    EntityManager em = emf.createEntityManager();

    Query q = em.createquery("UPDATE Hasta h SET h.adi=:ad,h.Soyadi=:Soyad,h.idDoktor=:did  WHERE h.id=:id");
    q.setParameter("ad",txt_hastaadi.getText());
    q.setParameter("Soyad",txt_hastaSoyadi.getText());
    q.setParameter("did",doktorlar.get(cmb_doktorlar.getSelectedindex()).getId());
    q.setParameter("id",tbl_hastalar.getValueAt(tbl_hastalar.getSelectedRow(),0));
    em.getTransaction().begin();
    q.executeUpdate();
    em.getTransaction().commit();
    ///
    dtm.setRowCount(0);
    q = em.createquery("SELECT h FROM Hasta h");

    List<Hasta> hastalar = q.getResultList();
    for (Hasta hs : hastalar) {
        dtm.addRow(new Object[]{hs.getId(),hs.getIdDoktor()});
    }
    tbl_hastalar.setModel(dtm);


}
项目:TextClassifier    文件Emfprovider.java   
public EntityManagerFactory getEntityManagerFactory(String persistenceUnitName) {
  if (emf == null) {
    emf = Persistence.createEntityManagerFactory(persistenceUnitName);
  }

  return emf;
}
项目:Java_Swing_Programming    文件Soru1.java   
private void btn_tutaractionPerformed(java.awt.event.ActionEvent evt) {//GEN-FirsT:event_btn_tutaractionPerformed
        // Todo add your handling code here:


            // Todo add your handling code here:
            EntityManagerFactory emf = Persistence.createEntityManagerFactory("BP2_LAB2PU");
            EntityManager em = emf.createEntityManager();
            Query q = em.createquery("SELECT m FROM Musteri m");
            List<Musteri> musteriler = q.getResultList();
            for (Musteri musteri : musteriler) {
                q = em.createquery("SELECT s FROM Satis s WHERE s.idMusteri=:id");
                q.setParameter("id",musteri.getId());
                List<Satis> satislar = q.getResultList();
                int toplam = 0;

                for (Satis satis : satislar) {
                    toplam += satis.getTutar();
                }

                System.out.println(musteri.getId()+" "+toplam);

            }
//            
//            Query q = em.createquery("SELECT sum(s.tutar) FROM Satis s Group By s.idMusteri ");
//            List<Object> satislar = q.getResultList();
//            for (Object satis : satislar) {
//                System.out.println(""+(Long)satis);
//        }



    }
项目:citizensLoader4a    文件Hibernate_Jpa.java   
/**
 * Gets the emf.
 *
 * @return the emf
 */
private static EntityManagerFactory getEmf() {
    if (emf == null) {
        String persistenceUnitName = loadPersistentUnitName();
        emf = Persistence.createEntityManagerFactory(persistenceUnitName);
    }
    return emf;
}
项目:ProjetoFinalInitium    文件CidadeTest.java   
@Test
public void selectHqltest() {
    EntityManagerFactory factory = Persistence.createEntityManagerFactory("db1start");
    EntityManager manager = factory.createEntityManager();

    Query query = manager.createquery("Select c from Cidade c");
    List<Cidade> cidades = query.getResultList();

    for (Cidade cidade : cidades) {
        System.out.println(cidade.getNome());
        System.out.println(cidade.getId());
        System.out.println(cidade.getUf().getNome());
    }

}
项目:JPA-Demo    文件JPARead.java   
public static void main(String[] args) throws Exception {
    // Get the entity manager
    EntityManager em = Persistence.createEntityManagerFactory("company-provider").createEntityManager();
    em.getTransaction().begin();
    em.createNativeQuery("PRAGMA foreign_keys=ON").executeUpdate();
    em.getTransaction().commit();

    // Search in departments by name
    BufferedReader reader = new BufferedReader(new InputStreamReader(system.in));
    System.out.print("Write the department's name: ");
    String name = reader.readLine();
    System.out.println("Matching departments:");
    Query q1 = em.createNativeQuery("SELECT * FROM departments WHERE name LIKE ?",Department.class);
    q1.setParameter(1,"%" + name + "%");
    List<Department> deps = (List<Department>) q1.getResultList();
    // Print the departments
    for (Department department : deps) {
        System.out.println(department);
    }

    // Get just one department
    // Only use this while looking by unique fields,if not,// you Could get duplicate results
    System.out.print("Write the department's ID: ");
    int dep_id = Integer.parseInt(reader.readLine());
    Query q2 = em.createNativeQuery("SELECT * FROM departments WHERE id = ?",Department.class);
    q2.setParameter(1,dep_id);
    Department dep = (Department) q2.getSingleResult();
    // Print the department
    System.out.println(dep);

    // Close the entity manager
    em.close();
}
项目:bibliometrics    文件AuthorBuilder.java   
/**
   * gets an author from the database by determining the type of the provided id. if no author is present it builds one from the id.
   * @param id the author identifier
   * @return the author retrieved from the database or build with the identifier
* @throws JDOMException thrown upon parsing the source response
* @throws IOException thrown upon reading profiles from disc
* @throws SAXException thrown when parsing the files from disc
 */
  public PublicationAuthor retrieveAuthor(String id) throws JDOMException,IOException,SAXException {
      typeOfID = determineID(id);
      LOGGER.info("given ID: " + id + " is of type " + typeOfID);
      EntityManagerFactory emf = Persistence.createEntityManagerFactory("publicationAuthors");
      EntityManager em = emf.createEntityManager();
      CriteriaBuilder cb = em.getCriteriaBuilder();
      CriteriaQuery<PublicationAuthor> q = cb.createquery(PublicationAuthor.class);
      Root<PublicationAuthor> c = q.from(PublicationAuthor.class);
      List<Predicate> predicates = new ArrayList<>();
      if (typeOfID.equals("surname")) {
          if (id.contains(",")) {
              predicates.add(cb.equal(c.get("surname"),id.substring(0,id.indexOf(","))));
              predicates.add(cb.equal(c.get("firstname"),id.substring(id.indexOf(",")+1)));
              LOGGER.info("retriving surname,firstname from database for " + id);
          } else if (id.contains(" ")) {
              predicates.add(cb.equal(c.get("firstname"),id.indexOf(" "))));
              predicates.add(cb.equal(c.get("surname"),id.substring(id.indexOf(" ")+1)));
              LOGGER.info("retrieving firstname surname from database for " + id);
          } else {
              predicates.add(cb.equal(c.get("surname"),id));
              LOGGER.info("retrieving surname from database for " + id);
          }
      }
      predicates.add(cb.equal(c.get(typeOfID),id));
      q.select(c).where(cb.equal(c.get(typeOfID),id));
      TypedQuery<PublicationAuthor> query = em.createquery(q);
      List<PublicationAuthor> authors = query.getResultList();
      em.close();
      if (authors.size() == 1) {
          LOGGER.info("found author in database");
          this.author = authors.get(0);
          return author;
      }
      LOGGER.info("no match in database");
      return buildAuthor(id);
  }
项目:aries-jpa    文件TaskServiceImpltest.java   
private EntityManagerFactory createTestemF() {
    Map<String,String> properties = new HashMap<String,String>();
    properties.put("javax.persistence.jdbc.driver","org.apache.derby.jdbc.EmbeddedDriver");
    properties.put("javax.persistence.jdbc.url","jdbc:derby:memory:TEST;create=true");
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("tasklist",properties);
    return emf;
}
项目:aries-jpa    文件TaskServiceImpltest.java   
private EntityManagerFactory createTestemF() {
    Map<String,"jdbc:derby:target/test;create=true");
    EntityManagerFactory emf = Persistence.createEntityManagerFactory("tasklist",properties);
    return emf;
}
项目:ProjetoFinalInitium    文件CidadeTest.java   
@Test
public void updatetest() {
    EntityManagerFactory factory = Persistence.createEntityManagerFactory("db1start");
    EntityManager manager = factory.createEntityManager();

    Cidade cidade = manager.find(Cidade.class,2L);
    cidade.setNome("Maringa");
    manager.getTransaction().begin();
    manager.persist(cidade);
    manager.getTransaction().commit();

    factory.close();

}
项目:spring-data-examples    文件BasicSample.java   
/**
 * Sets up a {@link SimpleJpaRepository} instance.
 */
@Before
public void setUp() {

    EntityManagerFactory factory = Persistence.createEntityManagerFactory("jpa.sample.plain");
    em = factory.createEntityManager();

    userRepository = new SimpleJpaRepository<User,Long>(User.class,em);

    em.getTransaction().begin();
}
项目:cloud-ariba-discovery-rfx-to-external-marketplace-ext    文件EntityManagerFactoryProvider.java   
private static void initEntityManagerFactory(DataSource dataSource) {
    logger.debug(DEBUG_INITIALIZING_ENTITY_MANAGER_FACTORY);

    Map<Object,Object> properties = new HashMap<>();
    properties.put(PersistenceUnitProperties.NON_JTA_DATASOURCE,dataSource);

    EntityManagerFactoryProvider.entityManagerFactory = Persistence
            .createEntityManagerFactory(PublicSourcingPersistenceUnit.NAME,properties);

    logger.debug(DEBUG_ENTITY_MANAGER_FACTORY_INITIALIZED);
}
项目:Pet-Supply-Store    文件EMFManager.java   
/**
 * Get the entity manager factory.
 * @return The entity manager factory.
 */
static EntityManagerFactory getEMF() {
    if (emf == null) {
        HashMap<String,String> persistenceProperties = EMFManager.persistenceProperties;
        if (persistenceProperties == null) {
            persistenceProperties = createPersistencePropertiesFromJavaEnv();
        }
        emf = Persistence.createEntityManagerFactory("tools.descartes.petsupplystore.persistence",persistenceProperties);

    }
    return emf;
}
项目:redg    文件JpametamodelRedGProvider.java   
public static JpametamodelRedGProvider fromPersistenceUnit(String perstistenceUnitName) {
    Properties properties = new Properties();
    properties.setProperty("hibernate.dialect","org.hibernate.dialect.H2Dialect");
    EntityManagerFactory entityManagerFactory = Persistence.createEntityManagerFactory(perstistenceUnitName,properties);

    EntityManager entityManager = entityManagerFactory.createEntityManager();
    return new JpametamodelRedGProvider(entityManager.getmetamodel());
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。