Tang Anping

package ?com;

import ?java.io.Serializable;

public ? class ?Student? implements ?Serializable? {
???? private ?String?name;
???? private ? int ?age;
???? private ?Student()? {
????????
????}
???? public ?Student(String?name,? int ?age)? {
???????? this .name? = ?name;
???????? this .age? = ?age;
????}
???? /**?*/ /**
?????*? @return ?the?age
????? */
???? public ? int ?getAge()? {
???????? return ?age;
????}
???? /**?*/ /**
?????*? @param ?age?the?age?to?set
????? */
???? public ? void ?setAge( int ?age)? {
???????? this .age? = ?age;
????}
???? /**?*/ /**
?????*? @return ?the?name
????? */
???? public ?String?getName()? {
???????? return ?name;
????}
???? /**?*/ /**
?????*? @param ?name?the?name?to?set
????? */
???? public ? void ?setName(String?name)? {
???????? this .name? = ?name;
????}
????
}

<? xml?version = " 1.0 " ?encoding = " UTF-8 " ?>

< jdo >
???? < package ?name = " com " >
???????? < class ?name = " Student " />
???? </ package >
</ jdo >

<? xml?version = " 1.0 " ?encoding = " UTF-8 " ?>

< mapping >
???? < package ?name = " com " >
???????? < class ?name = " Student " >
???????????? < jdbc - class - map?type = " base " ?pk - column = " JDOID " ?table = " STUDENT " />
???????????? < field?name = " age " >
???????????????? < jdbc - field - map?type = " value " ?column = " AGE " />
???????????? </ field >
???????????? < field?name = " name " >
???????????????? < jdbc - field - map?type = " value " ?column = " NAME " />
???????????? </ field >
???????? </ class >
???? </ package >
</ mapping >

kodo.LicenseKey:?2C61 - EF63 - F131 - 32B2 - 3200
kodo.FetchGroups:?
kodo.WriteLockLevel:?write
kodo.RestoreMutableValues:? false
kodo.CopyObjectIds:? false
kodo.PersistentClasses:?com.Student
kodo.RetryClassRegistration:? false
javax.jdo.PersistenceManagerFactoryClass:?kodo.jdbc.runtime.JDBCPersistenceManagerFactory
javax.jdo.option.NontransactionalWrite:? false
javax.jdo.option.Multithreaded:? false
javax.jdo.option.ConnectionUserName:?root
javax.jdo.option.ConnectionPassword:?admin
javax.jdo.option.ConnectionURL:?jdbc\:mysql\: // localhost:3306/bikestore
javax.jdo.option.ConnectionDriverName:?com.mysql.jdbc.Driver
kodo.jdbc.Schemas:?
kodo.jdbc.ForeignKeyConstraints:? false

package ?com.test;

import ?java.io.FileInputStream;
import ?java.io.FileNotFoundException;
import ?java.io.IOException;
import ?java.io.InputStream;
import ?java.util.List;
import ?java.util.Properties;

import ?javax.jdo.JDOHelper;
import ?javax.jdo.PersistenceManager;
import ?javax.jdo.PersistenceManagerFactory;
import ?javax.jdo.Query;
import ?javax.jdo.Transaction;

import ?org.apache.log4j.Logger;

import ?com.Student;

import ?junit.framework.TestCase;

public ? class ?StudentTest? extends ?TestCase? {
private ? static ? final ?Logger?log? = ?Logger.getLogger(StudentTest. class );
????
???? private ?PersistenceManagerFactory?factory;
???? private ?PersistenceManager?manager;
????
???? /**?*/ /**
?????*?初始化持久化工廠類
????? */
???? public ? void ?setUp()? {
???????? try ? {
????????????InputStream?in? = ? new ?FileInputStream( " src/kodo.properties " );
????????????
// ????????????factory?=?JDOHelper.getPersistenceManagerFactory(in);
???????????? // ?或者
????????????Properties?props? = ? new ?Properties();
????????????props.load(in);
????????????in.close();
????????????factory? = ?JDOHelper.getPersistenceManagerFactory(props);
????????????
????????????manager? = ?factory.getPersistenceManager();
????????????log.info(factory? + ? " ???? " ? + ?manager);
????????} ? catch ?(FileNotFoundException?e)? {
????????????e.printStackTrace();
????????} ? catch ?(IOException?e)? {
????????????e.printStackTrace();
????????}
????}
???? /**?*/ /**
?????*?釋放資源
????? */
???? public ? void ?tearDown()? {
????????manager? = ? null ;
????????factory? = ? null ;
????????
????}

???? public ? void ?testSaveUser()? {
????????Student?student? = ? new ?Student( " tang " ,? 23 );
???????? try ? {
????????????Transaction?tran? = ?manager.currentTransaction();
????????????tran.begin();
????????????manager.makePersistent(student);
????????????tran.commit();
????????????log.info( " 保存成功 " );
????????} ? catch ?(Exception?e)? {
????????????e.printStackTrace();
????????????log.error( " 保存異常 " ,?e);
????????}
????}
???? public ? void ?testGetStudent()? {
???????? try ? {
???????????? // ?主鍵ID不能作為條件,否則會報異常
????????????Query?query? = ?(Query)manager.newQuery(Student. class ,? " name?==?'ddd' " );
????????????List?list? = ?(List)query.execute();
????????????Student?stu? = ?(Student)list.get( 0 );
????????????log.info( "" ? + ?stu.getAge());
????????????log.info( " 獲取成功 " );
????????} ? catch ?(Exception?e)? {
????????????e.printStackTrace();
????????????log.error( " 獲取異常 " ,?e);
????????}
????}
???? public ? void ?testGetStudents()? {
???????? try ? {
????????????Query?query? = ?(Query)manager.newQuery(Student. class );
????????????List?list? = ?(List)query.execute();
????????????log.info( "" ? + ?list.size());
????????????log.info( " 獲取所有成功 " );
????????} ? catch ?(Exception?e)? {
????????????e.printStackTrace();
????????????log.error( " 獲取所有異常 " ,?e);
????????}
????}
???? public ? void ?testDeleteStudents()? {
???????? try ? {
???????????? // ?主鍵ID不能作為條件,否則會報異常,可以批量刪除
????????????Query?query? = ?(Query)manager.newQuery(Student. class ,? " name?==?'tang' " );
????????????List?list? = ?(List)query.execute();
????????????log.info( "" ? + ?list.size());
????????????Transaction?tran? = ?manager.currentTransaction();
????????????tran.begin();
????????????manager.deletePersistentAll(list);
????????????tran.commit();
????????????log.info( " 刪除一批成功 " );
????????} ? catch ?(Exception?e)? {
????????????e.printStackTrace();
????????????log.error( " 刪除一批異常 " ,?e);
????????}
????}

???? public ? void ?testUpdateStudent()? {
???????? try ? {
????????????Transaction?tran? = ?manager.currentTransaction();
????????????tran.begin();
????????????Query?query? = ?(Query)manager.newQuery(Student. class );
????????????List?list? = ?(List)query.execute();
????????????Student?Student? = ?(Student)list.get( 0 );
????????????Student.setName( " ddddddd " );
????????????Student.setAge( 26 );
???????????? // ?javax.jdo.option.NontransactionalWrite:?true
???????????? // ?設置為true,不會報異常,但是不會更新數據庫
???????????? // ?事務從這里開始不行,會報在事務外的異常
// ????????????tran.begin();
????????????manager.makePersistent(Student);
????????????tran.commit();
????????????
????????????log.info( "" ? + ?list.size());
????????????log.info( " 更新成功 " );
????????} ? catch ?(Exception?e)? {
????????????e.printStackTrace();
????????????log.error( " 更新異常 " ,?e);
????????}
????}
}