You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

DatabaseTest.java 32KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038
  1. /*
  2. Copyright (c) 2007 Health Market Science, Inc.
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. http://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package com.healthmarketscience.jackcess;
  14. import java.io.File;
  15. import java.io.FileNotFoundException;
  16. import java.io.IOException;
  17. import java.math.BigDecimal;
  18. import java.text.DateFormat;
  19. import java.text.SimpleDateFormat;
  20. import java.time.ZoneId;
  21. import java.util.ArrayList;
  22. import java.util.Arrays;
  23. import java.util.Calendar;
  24. import java.util.Date;
  25. import java.util.HashSet;
  26. import java.util.LinkedHashMap;
  27. import java.util.List;
  28. import java.util.Map;
  29. import java.util.Set;
  30. import java.util.TimeZone;
  31. import java.util.TreeSet;
  32. import java.util.UUID;
  33. import java.util.stream.Collectors;
  34. import static com.healthmarketscience.jackcess.Database.*;
  35. import static com.healthmarketscience.jackcess.DatabaseBuilder.*;
  36. import static com.healthmarketscience.jackcess.TestUtil.*;
  37. import com.healthmarketscience.jackcess.impl.ColumnImpl;
  38. import com.healthmarketscience.jackcess.impl.DatabaseImpl;
  39. import static com.healthmarketscience.jackcess.impl.JetFormatTest.*;
  40. import com.healthmarketscience.jackcess.impl.RowIdImpl;
  41. import com.healthmarketscience.jackcess.impl.RowImpl;
  42. import com.healthmarketscience.jackcess.impl.TableImpl;
  43. import com.healthmarketscience.jackcess.util.RowFilterTest;
  44. import junit.framework.TestCase;
  45. /**
  46. * @author Tim McCune
  47. */
  48. @SuppressWarnings("deprecation")
  49. public class DatabaseTest extends TestCase
  50. {
  51. public DatabaseTest(String name) throws Exception {
  52. super(name);
  53. }
  54. public void testInvalidTableDefs() throws Exception {
  55. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  56. Database db = create(fileFormat);
  57. try {
  58. newTable("test").toTable(db);
  59. fail("created table with no columns?");
  60. } catch(IllegalArgumentException e) {
  61. // success
  62. }
  63. try {
  64. newTable("test")
  65. .addColumn(newColumn("A", DataType.TEXT))
  66. .addColumn(newColumn("a", DataType.MEMO))
  67. .toTable(db);
  68. fail("created table with duplicate column names?");
  69. } catch(IllegalArgumentException e) {
  70. // success
  71. }
  72. try {
  73. newTable("test")
  74. .addColumn(newColumn("A", DataType.TEXT)
  75. .setLengthInUnits(352))
  76. .toTable(db);
  77. fail("created table with invalid column length?");
  78. } catch(IllegalArgumentException e) {
  79. // success
  80. }
  81. try {
  82. newTable("test")
  83. .addColumn(newColumn("A_" + createString(70), DataType.TEXT))
  84. .toTable(db);
  85. fail("created table with too long column name?");
  86. } catch(IllegalArgumentException e) {
  87. // success
  88. }
  89. newTable("test")
  90. .addColumn(newColumn("A", DataType.TEXT))
  91. .toTable(db);
  92. try {
  93. newTable("Test")
  94. .addColumn(newColumn("A", DataType.TEXT))
  95. .toTable(db);
  96. fail("create duplicate tables?");
  97. } catch(IllegalArgumentException e) {
  98. // success
  99. }
  100. db.close();
  101. }
  102. }
  103. public void testReadDeletedRows() throws Exception {
  104. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.DEL, true)) {
  105. Table table = open(testDB).getTable("Table");
  106. int rows = 0;
  107. while (table.getNextRow() != null) {
  108. rows++;
  109. }
  110. assertEquals(2, rows);
  111. table.getDatabase().close();
  112. }
  113. }
  114. public void testGetColumns() throws Exception {
  115. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  116. List<? extends Column> columns = open(testDB).getTable("Table1").getColumns();
  117. assertEquals(9, columns.size());
  118. checkColumn(columns, 0, "A", DataType.TEXT);
  119. checkColumn(columns, 1, "B", DataType.TEXT);
  120. checkColumn(columns, 2, "C", DataType.BYTE);
  121. checkColumn(columns, 3, "D", DataType.INT);
  122. checkColumn(columns, 4, "E", DataType.LONG);
  123. checkColumn(columns, 5, "F", DataType.DOUBLE);
  124. checkColumn(columns, 6, "G", DataType.SHORT_DATE_TIME);
  125. checkColumn(columns, 7, "H", DataType.MONEY);
  126. checkColumn(columns, 8, "I", DataType.BOOLEAN);
  127. }
  128. }
  129. private static void checkColumn(
  130. List<? extends Column> columns, int columnNumber, String name,
  131. DataType dataType)
  132. throws Exception
  133. {
  134. Column column = columns.get(columnNumber);
  135. assertEquals(name, column.getName());
  136. assertEquals(dataType, column.getType());
  137. }
  138. public void testGetNextRow() throws Exception {
  139. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  140. final Database db = open(testDB);
  141. db.setDateTimeType(DateTimeType.DATE);
  142. assertEquals(4, db.getTableNames().size());
  143. final Table table = db.getTable("Table1");
  144. Row row1 = table.getNextRow();
  145. Row row2 = table.getNextRow();
  146. if(!"abcdefg".equals(row1.get("A"))) {
  147. Row tmpRow = row1;
  148. row1 = row2;
  149. row2 = tmpRow;
  150. }
  151. checkTestDBTable1RowABCDEFG(testDB, table, row1);
  152. checkTestDBTable1RowA(testDB, table, row2);
  153. db.close();
  154. }
  155. }
  156. public void testCreate() throws Exception {
  157. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  158. Database db = create(fileFormat);
  159. assertEquals(0, db.getTableNames().size());
  160. db.close();
  161. }
  162. }
  163. public void testDeleteCurrentRow() throws Exception {
  164. // make sure correct row is deleted
  165. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  166. Database db = createMem(fileFormat);
  167. createTestTable(db);
  168. Map<String,Object> row1 = createTestRowMap("Tim1");
  169. Map<String,Object> row2 = createTestRowMap("Tim2");
  170. Map<String,Object> row3 = createTestRowMap("Tim3");
  171. Table table = db.getTable("Test");
  172. @SuppressWarnings("unchecked")
  173. List<Map<String,Object>> rows = Arrays.asList(row1, row2, row3);
  174. table.addRowsFromMaps(rows);
  175. assertRowCount(3, table);
  176. table.reset();
  177. table.getNextRow();
  178. table.getNextRow();
  179. table.getDefaultCursor().deleteCurrentRow();
  180. table.reset();
  181. Map<String, Object> outRow = table.getNextRow();
  182. assertEquals("Tim1", outRow.get("A"));
  183. outRow = table.getNextRow();
  184. assertEquals("Tim3", outRow.get("A"));
  185. assertRowCount(2, table);
  186. db.close();
  187. // test multi row delete/add
  188. db = createMem(fileFormat);
  189. createTestTable(db);
  190. Object[] row = createTestRow();
  191. table = db.getTable("Test");
  192. for (int i = 0; i < 10; i++) {
  193. row[3] = i;
  194. table.addRow(row);
  195. }
  196. row[3] = 1974;
  197. assertRowCount(10, table);
  198. table.reset();
  199. table.getNextRow();
  200. table.getDefaultCursor().deleteCurrentRow();
  201. assertRowCount(9, table);
  202. table.reset();
  203. table.getNextRow();
  204. table.getDefaultCursor().deleteCurrentRow();
  205. assertRowCount(8, table);
  206. table.reset();
  207. for (int i = 0; i < 8; i++) {
  208. table.getNextRow();
  209. }
  210. table.getDefaultCursor().deleteCurrentRow();
  211. assertRowCount(7, table);
  212. table.addRow(row);
  213. assertRowCount(8, table);
  214. table.reset();
  215. for (int i = 0; i < 3; i++) {
  216. table.getNextRow();
  217. }
  218. table.getDefaultCursor().deleteCurrentRow();
  219. assertRowCount(7, table);
  220. table.reset();
  221. assertEquals(2, table.getNextRow().get("D"));
  222. db.close();
  223. }
  224. }
  225. public void testDeleteRow() throws Exception {
  226. // make sure correct row is deleted
  227. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  228. Database db = createMem(fileFormat);
  229. createTestTable(db);
  230. Table table = db.getTable("Test");
  231. for(int i = 0; i < 10; ++i) {
  232. table.addRowFromMap(createTestRowMap("Tim" + i));
  233. }
  234. assertRowCount(10, table);
  235. table.reset();
  236. List<Row> rows = RowFilterTest.toList(table);
  237. Row r1 = rows.remove(7);
  238. Row r2 = rows.remove(3);
  239. assertEquals(8, rows.size());
  240. assertSame(r2, table.deleteRow(r2));
  241. assertSame(r1, table.deleteRow(r1));
  242. assertTable(rows, table);
  243. table.deleteRow(r2);
  244. table.deleteRow(r1);
  245. assertTable(rows, table);
  246. }
  247. }
  248. public void testMissingFile() throws Exception {
  249. File bogusFile = new File("fooby-dooby.mdb");
  250. assertTrue(!bogusFile.exists());
  251. try {
  252. newDatabase(bogusFile).setReadOnly(true).
  253. setAutoSync(getTestAutoSync()).open();
  254. fail("FileNotFoundException should have been thrown");
  255. } catch(FileNotFoundException e) {
  256. }
  257. assertTrue(!bogusFile.exists());
  258. }
  259. public void testReadWithDeletedCols() throws Exception {
  260. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.DEL_COL, true)) {
  261. Table table = open(testDB).getTable("Table1");
  262. Map<String, Object> expectedRow0 = new LinkedHashMap<String, Object>();
  263. expectedRow0.put("id", 0);
  264. expectedRow0.put("id2", 2);
  265. expectedRow0.put("data", "foo");
  266. expectedRow0.put("data2", "foo2");
  267. Map<String, Object> expectedRow1 = new LinkedHashMap<String, Object>();
  268. expectedRow1.put("id", 3);
  269. expectedRow1.put("id2", 5);
  270. expectedRow1.put("data", "bar");
  271. expectedRow1.put("data2", "bar2");
  272. int rowNum = 0;
  273. Map<String, Object> row = null;
  274. while ((row = table.getNextRow()) != null) {
  275. if(rowNum == 0) {
  276. assertEquals(expectedRow0, row);
  277. } else if(rowNum == 1) {
  278. assertEquals(expectedRow1, row);
  279. } else if(rowNum >= 2) {
  280. fail("should only have 2 rows");
  281. }
  282. rowNum++;
  283. }
  284. table.getDatabase().close();
  285. }
  286. }
  287. public void testCurrency() throws Exception {
  288. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  289. Database db = create(fileFormat);
  290. Table table = newTable("test")
  291. .addColumn(newColumn("A", DataType.MONEY))
  292. .toTable(db);
  293. table.addRow(new BigDecimal("-2341234.03450"));
  294. table.addRow(37L);
  295. table.addRow("10000.45");
  296. table.reset();
  297. List<Object> foundValues = new ArrayList<Object>();
  298. Map<String, Object> row = null;
  299. while((row = table.getNextRow()) != null) {
  300. foundValues.add(row.get("A"));
  301. }
  302. assertEquals(Arrays.asList(
  303. new BigDecimal("-2341234.0345"),
  304. new BigDecimal("37.0000"),
  305. new BigDecimal("10000.4500")),
  306. foundValues);
  307. try {
  308. table.addRow(new BigDecimal("342523234145343543.3453"));
  309. fail("IOException should have been thrown");
  310. } catch(IOException e) {
  311. // ignored
  312. }
  313. db.close();
  314. }
  315. }
  316. public void testGUID() throws Exception
  317. {
  318. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  319. Database db = create(fileFormat);
  320. Table table = newTable("test")
  321. .addColumn(newColumn("A", DataType.GUID))
  322. .toTable(db);
  323. table.addRow("{32A59F01-AA34-3E29-453F-4523453CD2E6}");
  324. table.addRow("{32a59f01-aa34-3e29-453f-4523453cd2e6}");
  325. table.addRow("{11111111-1111-1111-1111-111111111111}");
  326. table.addRow(" {FFFFFFFF-FFFF-FFFF-FFFF-FFFFFFFFFFFF} ");
  327. table.addRow(UUID.fromString("32a59f01-1234-3e29-4aaf-4523453cd2e6"));
  328. table.reset();
  329. List<Object> foundValues = new ArrayList<Object>();
  330. Map<String, Object> row = null;
  331. while((row = table.getNextRow()) != null) {
  332. foundValues.add(row.get("A"));
  333. }
  334. assertEquals(Arrays.asList(
  335. "{32A59F01-AA34-3E29-453F-4523453CD2E6}",
  336. "{32A59F01-AA34-3E29-453F-4523453CD2E6}",
  337. "{11111111-1111-1111-1111-111111111111}",
  338. "{FFFFFFFF-FFFF-FFFF-FFFF-FFFFFFFFFFFF}",
  339. "{32A59F01-1234-3E29-4AAF-4523453CD2E6}"),
  340. foundValues);
  341. try {
  342. table.addRow("3245234");
  343. fail("IOException should have been thrown");
  344. } catch(IOException e) {
  345. // ignored
  346. }
  347. db.close();
  348. }
  349. }
  350. public void testNumeric() throws Exception
  351. {
  352. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  353. Database db = create(fileFormat);
  354. ColumnBuilder col = newColumn("A", DataType.NUMERIC)
  355. .setScale(4).setPrecision(8).toColumn();
  356. assertTrue(col.getType().isVariableLength());
  357. Table table = newTable("test")
  358. .addColumn(col)
  359. .addColumn(newColumn("B", DataType.NUMERIC)
  360. .setScale(8).setPrecision(28))
  361. .toTable(db);
  362. table.addRow(new BigDecimal("-1234.03450"),
  363. new BigDecimal("23923434453436.36234219"));
  364. table.addRow(37L, 37L);
  365. table.addRow("1000.45", "-3452345321000");
  366. table.reset();
  367. List<Object> foundSmallValues = new ArrayList<Object>();
  368. List<Object> foundBigValues = new ArrayList<Object>();
  369. Map<String, Object> row = null;
  370. while((row = table.getNextRow()) != null) {
  371. foundSmallValues.add(row.get("A"));
  372. foundBigValues.add(row.get("B"));
  373. }
  374. assertEquals(Arrays.asList(
  375. new BigDecimal("-1234.0345"),
  376. new BigDecimal("37.0000"),
  377. new BigDecimal("1000.4500")),
  378. foundSmallValues);
  379. assertEquals(Arrays.asList(
  380. new BigDecimal("23923434453436.36234219"),
  381. new BigDecimal("37.00000000"),
  382. new BigDecimal("-3452345321000.00000000")),
  383. foundBigValues);
  384. try {
  385. table.addRow(new BigDecimal("3245234.234"),
  386. new BigDecimal("3245234.234"));
  387. fail("IOException should have been thrown");
  388. } catch(IOException e) {
  389. // ignored
  390. }
  391. db.close();
  392. }
  393. }
  394. public void testFixedNumeric() throws Exception
  395. {
  396. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.FIXED_NUMERIC)) {
  397. Database db = openCopy(testDB);
  398. Table t = db.getTable("test");
  399. boolean first = true;
  400. for(Column col : t.getColumns()) {
  401. if(first) {
  402. assertTrue(col.isVariableLength());
  403. assertEquals(DataType.MEMO, col.getType());
  404. first = false;
  405. } else {
  406. assertFalse(col.isVariableLength());
  407. assertEquals(DataType.NUMERIC, col.getType());
  408. }
  409. }
  410. Map<String, Object> row = t.getNextRow();
  411. assertEquals("some data", row.get("col1"));
  412. assertEquals(new BigDecimal("1"), row.get("col2"));
  413. assertEquals(new BigDecimal("0"), row.get("col3"));
  414. assertEquals(new BigDecimal("0"), row.get("col4"));
  415. assertEquals(new BigDecimal("4"), row.get("col5"));
  416. assertEquals(new BigDecimal("-1"), row.get("col6"));
  417. assertEquals(new BigDecimal("1"), row.get("col7"));
  418. Object[] tmpRow = new Object[]{
  419. "foo", new BigDecimal("1"), new BigDecimal(3), new BigDecimal("13"),
  420. new BigDecimal("-17"), new BigDecimal("0"), new BigDecimal("8734")};
  421. t.addRow(tmpRow);
  422. t.reset();
  423. t.getNextRow();
  424. row = t.getNextRow();
  425. assertEquals(tmpRow[0], row.get("col1"));
  426. assertEquals(tmpRow[1], row.get("col2"));
  427. assertEquals(tmpRow[2], row.get("col3"));
  428. assertEquals(tmpRow[3], row.get("col4"));
  429. assertEquals(tmpRow[4], row.get("col5"));
  430. assertEquals(tmpRow[5], row.get("col6"));
  431. assertEquals(tmpRow[6], row.get("col7"));
  432. db.close();
  433. }
  434. }
  435. public void testMultiPageTableDef() throws Exception
  436. {
  437. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  438. List<? extends Column> columns = open(testDB).getTable("Table2").getColumns();
  439. assertEquals(89, columns.size());
  440. }
  441. }
  442. public void testOverflow() throws Exception
  443. {
  444. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.OVERFLOW, true)) {
  445. Database mdb = open(testDB);
  446. Table table = mdb.getTable("Table1");
  447. // 7 rows, 3 and 5 are overflow
  448. table.getNextRow();
  449. table.getNextRow();
  450. Map<String, Object> row = table.getNextRow();
  451. assertEquals(Arrays.<Object>asList(
  452. null, "row3col3", null, null, null, null, null,
  453. "row3col9", null),
  454. new ArrayList<Object>(row.values()));
  455. table.getNextRow();
  456. row = table.getNextRow();
  457. assertEquals(Arrays.<Object>asList(
  458. null, "row5col2", null, null, null, null, null, null,
  459. null),
  460. new ArrayList<Object>(row.values()));
  461. table.reset();
  462. assertRowCount(7, table);
  463. mdb.close();
  464. }
  465. }
  466. public void testUsageMapPromotion() throws Exception {
  467. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.PROMOTION)) {
  468. Database db = openMem(testDB);
  469. Table t = db.getTable("jobDB1");
  470. assertTrue(((TableImpl)t).getOwnedPagesCursor().getUsageMap().toString()
  471. .startsWith("InlineHandler"));
  472. String lval = createNonAsciiString(255); // "--255 chars long text--";
  473. ((DatabaseImpl)db).getPageChannel().startWrite();
  474. try {
  475. for(int i = 0; i < 1000; ++i) {
  476. t.addRow(i, 13, 57, lval, lval, lval, lval, lval, lval, 47.0d);
  477. }
  478. } finally {
  479. ((DatabaseImpl)db).getPageChannel().finishWrite();
  480. }
  481. Set<Integer> ids = t.stream()
  482. .map(r -> r.getInt("ID"))
  483. .collect(Collectors.toSet());
  484. assertEquals(1000, ids.size());
  485. assertTrue(((TableImpl)t).getOwnedPagesCursor().getUsageMap().toString()
  486. .startsWith("ReferenceHandler"));
  487. db.close();
  488. }
  489. }
  490. public void testLargeTableDef() throws Exception {
  491. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  492. Database db = create(fileFormat);
  493. final int numColumns = 90;
  494. List<ColumnBuilder> columns = new ArrayList<ColumnBuilder>();
  495. List<String> colNames = new ArrayList<String>();
  496. for(int i = 0; i < numColumns; ++i) {
  497. String colName = "MyColumnName" + i;
  498. colNames.add(colName);
  499. columns.add(newColumn(colName, DataType.TEXT).toColumn());
  500. }
  501. Table t = newTable("test")
  502. .addColumns(columns)
  503. .toTable(db);
  504. List<String> row = new ArrayList<String>();
  505. Map<String,Object> expectedRowData = new LinkedHashMap<String, Object>();
  506. for(int i = 0; i < numColumns; ++i) {
  507. String value = "" + i + " some row data";
  508. row.add(value);
  509. expectedRowData.put(colNames.get(i), value);
  510. }
  511. t.addRow(row.toArray());
  512. t.reset();
  513. assertEquals(expectedRowData, t.getNextRow());
  514. db.close();
  515. }
  516. }
  517. public void testWriteAndReadDate() throws Exception {
  518. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  519. Database db = createMem(fileFormat);
  520. db.setDateTimeType(DateTimeType.DATE);
  521. Table table = newTable("test")
  522. .addColumn(newColumn("name", DataType.TEXT))
  523. .addColumn(newColumn("date", DataType.SHORT_DATE_TIME))
  524. .toTable(db);
  525. // since jackcess does not really store millis, shave them off before
  526. // storing the current date/time
  527. long curTimeNoMillis = (System.currentTimeMillis() / 1000L);
  528. curTimeNoMillis *= 1000L;
  529. DateFormat df = new SimpleDateFormat("yyyyMMdd HH:mm:ss");
  530. List<Date> dates =
  531. new ArrayList<Date>(
  532. Arrays.asList(
  533. df.parse("19801231 00:00:00"),
  534. df.parse("19930513 14:43:27"),
  535. null,
  536. df.parse("20210102 02:37:00"),
  537. new Date(curTimeNoMillis)));
  538. Calendar c = Calendar.getInstance();
  539. for(int year = 1801; year < 2050; year +=3) {
  540. for(int month = 0; month <= 12; ++month) {
  541. for(int day = 1; day < 29; day += 3) {
  542. c.clear();
  543. c.set(Calendar.YEAR, year);
  544. c.set(Calendar.MONTH, month);
  545. c.set(Calendar.DAY_OF_MONTH, day);
  546. dates.add(c.getTime());
  547. }
  548. }
  549. }
  550. ((DatabaseImpl)db).getPageChannel().startWrite();
  551. try {
  552. for(Date d : dates) {
  553. table.addRow("row " + d, d);
  554. }
  555. } finally {
  556. ((DatabaseImpl)db).getPageChannel().finishWrite();
  557. }
  558. List<Date> foundDates = table.stream()
  559. .map(r -> r.getDate("date"))
  560. .collect(Collectors.toList());
  561. assertEquals(dates.size(), foundDates.size());
  562. for(int i = 0; i < dates.size(); ++i) {
  563. Date expected = dates.get(i);
  564. Date found = foundDates.get(i);
  565. assertSameDate(expected, found);
  566. }
  567. db.close();
  568. }
  569. }
  570. public void testAncientDatesWrite() throws Exception
  571. {
  572. SimpleDateFormat sdf = DatabaseBuilder.createDateFormat("yyyy-MM-dd");
  573. List<String> dates = Arrays.asList("1582-10-15", "1582-10-14",
  574. "1492-01-10", "1392-01-10");
  575. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  576. Database db = createMem(fileFormat);
  577. db.setDateTimeType(DateTimeType.DATE);
  578. Table table = newTable("test")
  579. .addColumn(newColumn("name", DataType.TEXT))
  580. .addColumn(newColumn("date", DataType.SHORT_DATE_TIME))
  581. .toTable(db);
  582. for(String dateStr : dates) {
  583. Date d = sdf.parse(dateStr);
  584. table.addRow("row " + dateStr, d);
  585. }
  586. List<String> foundDates = table.stream()
  587. .map(r -> sdf.format(r.getDate("date")))
  588. .collect(Collectors.toList());
  589. assertEquals(dates, foundDates);
  590. db.close();
  591. }
  592. }
  593. /**
  594. * Test ancient date handling against test database {@code oldDates*.accdb}.
  595. */
  596. public void testAncientDatesRead() throws Exception
  597. {
  598. TimeZone tz = TimeZone.getTimeZone("America/New_York");
  599. SimpleDateFormat sdf = DatabaseBuilder.createDateFormat("yyyy-MM-dd");
  600. sdf.getCalendar().setTimeZone(tz);
  601. List<String> dates = Arrays.asList("1582-10-15", "1582-10-14",
  602. "1492-01-10", "1392-01-10");
  603. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.OLD_DATES)) {
  604. Database db = openCopy(testDB);
  605. db.setTimeZone(tz); // explicitly set database time zone
  606. db.setDateTimeType(DateTimeType.DATE);
  607. Table t = db.getTable("Table1");
  608. List<String> foundDates = new ArrayList<String>();
  609. for(Row row : t) {
  610. foundDates.add(sdf.format(row.getDate("DateField")));
  611. }
  612. assertEquals(dates, foundDates);
  613. db.close();
  614. }
  615. }
  616. public void testSystemTable() throws Exception
  617. {
  618. for (final FileFormat fileFormat : SUPPORTED_FILEFORMATS) {
  619. Database db = create(fileFormat);
  620. Set<String> sysTables = new TreeSet<String>(
  621. String.CASE_INSENSITIVE_ORDER);
  622. sysTables.addAll(
  623. Arrays.asList("MSysObjects", "MSysQueries", "MSysACES",
  624. "MSysRelationships"));
  625. if (fileFormat == FileFormat.GENERIC_JET4) {
  626. assertNull("file format: " + fileFormat, db.getSystemTable("MSysAccessObjects"));
  627. } else if (fileFormat.ordinal() < FileFormat.V2003.ordinal()) {
  628. assertNotNull("file format: " + fileFormat, db.getSystemTable("MSysAccessObjects"));
  629. sysTables.add("MSysAccessObjects");
  630. } else {
  631. // v2003+ template files have no "MSysAccessObjects" table
  632. assertNull("file format: " + fileFormat, db.getSystemTable("MSysAccessObjects"));
  633. sysTables.addAll(
  634. Arrays.asList("MSysNavPaneGroupCategories",
  635. "MSysNavPaneGroups", "MSysNavPaneGroupToObjects",
  636. "MSysNavPaneObjectIDs", "MSysAccessStorage"));
  637. if(fileFormat.ordinal() >= FileFormat.V2007.ordinal()) {
  638. sysTables.addAll(
  639. Arrays.asList(
  640. "MSysComplexColumns", "MSysComplexType_Attachment",
  641. "MSysComplexType_Decimal", "MSysComplexType_GUID",
  642. "MSysComplexType_IEEEDouble", "MSysComplexType_IEEESingle",
  643. "MSysComplexType_Long", "MSysComplexType_Short",
  644. "MSysComplexType_Text", "MSysComplexType_UnsignedByte"));
  645. }
  646. if(fileFormat.ordinal() >= FileFormat.V2010.ordinal()) {
  647. sysTables.add("f_12D7448B56564D8AAE333BCC9B3718E5_Data");
  648. sysTables.add("MSysResources");
  649. }
  650. if(fileFormat.ordinal() >= FileFormat.V2019.ordinal()) {
  651. sysTables.remove("f_12D7448B56564D8AAE333BCC9B3718E5_Data");
  652. sysTables.add("f_8FA5340F56044616AE380F64A2FEC135_Data");
  653. sysTables.add("MSysWSDPCacheComplexColumnMapping");
  654. sysTables.add("MSysWSDPChangeTokenMapping");
  655. sysTables.add("MSysWSDPRelationshipMapping");
  656. }
  657. }
  658. assertEquals(sysTables, db.getSystemTableNames());
  659. assertNotNull(db.getSystemTable("MSysObjects"));
  660. assertNotNull(db.getSystemTable("MSysQueries"));
  661. assertNotNull(db.getSystemTable("MSysACES"));
  662. assertNotNull(db.getSystemTable("MSysRelationships"));
  663. assertNull(db.getSystemTable("MSysBogus"));
  664. TableMetaData tmd = db.getTableMetaData("MSysObjects");
  665. assertEquals("MSysObjects", tmd.getName());
  666. assertFalse(tmd.isLinked());
  667. assertTrue(tmd.isSystem());
  668. db.close();
  669. }
  670. }
  671. public void testFixedText() throws Exception
  672. {
  673. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.FIXED_TEXT)) {
  674. Database db = openCopy(testDB);
  675. Table t = db.getTable("users");
  676. Column c = t.getColumn("c_flag_");
  677. assertEquals(DataType.TEXT, c.getType());
  678. assertEquals(false, c.isVariableLength());
  679. assertEquals(2, c.getLength());
  680. Map<String,Object> row = t.getNextRow();
  681. assertEquals("N", row.get("c_flag_"));
  682. t.addRow(3, "testFixedText", "boo", "foo", "bob", 3, 5, 9, "Y",
  683. new Date());
  684. t.getNextRow();
  685. row = t.getNextRow();
  686. assertEquals("testFixedText", row.get("c_user_login"));
  687. assertEquals("Y", row.get("c_flag_"));
  688. db.close();
  689. }
  690. }
  691. public void testDbSortOrder() throws Exception {
  692. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  693. Database db = open(testDB);
  694. assertEquals(((DatabaseImpl)db).getFormat().DEFAULT_SORT_ORDER,
  695. ((DatabaseImpl)db).getDefaultSortOrder());
  696. db.close();
  697. }
  698. }
  699. public void testUnsupportedColumns() throws Exception {
  700. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.UNSUPPORTED)) {
  701. Database db = open(testDB);
  702. Table t = db.getTable("Test");
  703. Column varCol = t.getColumn("UnknownVar");
  704. assertEquals(DataType.UNSUPPORTED_VARLEN, varCol.getType());
  705. Column fixCol = t.getColumn("UnknownFix");
  706. assertEquals(DataType.UNSUPPORTED_FIXEDLEN, fixCol.getType());
  707. List<String> varVals = Arrays.asList(
  708. "RawData[(10) FF FE 73 6F 6D 65 64 61 74 61]",
  709. "RawData[(12) FF FE 6F 74 68 65 72 20 64 61 74 61]",
  710. null);
  711. List<String> fixVals = Arrays.asList("RawData[(4) 37 00 00 00]",
  712. "RawData[(4) F3 FF FF FF]",
  713. "RawData[(4) 02 00 00 00]");
  714. int idx = 0;
  715. for(Map<String,Object> row : t) {
  716. checkRawValue(varVals.get(idx), varCol.getRowValue(row));
  717. checkRawValue(fixVals.get(idx), fixCol.getRowValue(row));
  718. ++idx;
  719. }
  720. db.close();
  721. }
  722. }
  723. static List<Table> getTables(Iterable<Table> tableIter)
  724. {
  725. List<Table> tableList = new ArrayList<Table>();
  726. for(Table t : tableIter) {
  727. tableList.add(t);
  728. }
  729. return tableList;
  730. }
  731. public void testTimeZone() throws Exception
  732. {
  733. TimeZone tz = TimeZone.getTimeZone("America/New_York");
  734. doTestTimeZone(tz);
  735. tz = TimeZone.getTimeZone("Australia/Sydney");
  736. doTestTimeZone(tz);
  737. }
  738. private static void doTestTimeZone(final TimeZone tz) throws Exception
  739. {
  740. ColumnImpl col = new ColumnImpl(null, null, DataType.SHORT_DATE_TIME, 0, 0, 0) {
  741. @Override
  742. public TimeZone getTimeZone() { return tz; }
  743. @Override
  744. public ZoneId getZoneId() { return null; }
  745. @Override
  746. public ColumnImpl.DateTimeFactory getDateTimeFactory() {
  747. return getDateTimeFactory(DateTimeType.DATE);
  748. }
  749. };
  750. SimpleDateFormat df = new SimpleDateFormat("yyyy.MM.dd");
  751. df.setTimeZone(tz);
  752. long startDate = df.parse("2012.01.01").getTime();
  753. long endDate = df.parse("2013.01.01").getTime();
  754. Calendar curCal = Calendar.getInstance(tz);
  755. curCal.setTimeInMillis(startDate);
  756. SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss");
  757. sdf.setTimeZone(tz);
  758. while(curCal.getTimeInMillis() < endDate) {
  759. Date curDate = curCal.getTime();
  760. Date newDate = new Date(col.fromDateDouble(col.toDateDouble(curDate)));
  761. if(curDate.getTime() != newDate.getTime()) {
  762. assertEquals(sdf.format(curDate), sdf.format(newDate));
  763. }
  764. curCal.add(Calendar.MINUTE, 30);
  765. }
  766. }
  767. public void testToString()
  768. {
  769. RowImpl row = new RowImpl(new RowIdImpl(1, 1));
  770. row.put("id", 37);
  771. row.put("data", null);
  772. assertEquals("Row[1:1][{id=37,data=<null>}]", row.toString());
  773. }
  774. public void testIterateTableNames() throws Exception {
  775. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  776. final Database db = open(testDB);
  777. Set<String> names = new HashSet<>();
  778. int sysCount = 0;
  779. for(TableMetaData tmd : db.newTableMetaDataIterable()) {
  780. if(tmd.isSystem()) {
  781. ++sysCount;
  782. continue;
  783. }
  784. assertFalse(tmd.isLinked());
  785. assertNull(tmd.getLinkedTableName());
  786. assertNull(tmd.getLinkedDbName());
  787. names.add(tmd.getName());
  788. }
  789. assertTrue(sysCount > 4);
  790. assertEquals(new HashSet<>(Arrays.asList("Table1", "Table2", "Table3",
  791. "Table4")),
  792. names);
  793. }
  794. for (final TestDB testDB : TestDB.getSupportedForBasename(Basename.LINKED)) {
  795. final Database db = open(testDB);
  796. Set<String> names = new HashSet<>();
  797. for(TableMetaData tmd : db.newTableMetaDataIterable()) {
  798. if(tmd.isSystem()) {
  799. continue;
  800. }
  801. if("Table1".equals(tmd.getName())) {
  802. assertFalse(tmd.isLinked());
  803. assertNull(tmd.getLinkedTableName());
  804. assertNull(tmd.getLinkedDbName());
  805. } else {
  806. assertTrue(tmd.isLinked());
  807. assertEquals("Table1", tmd.getLinkedTableName());
  808. assertEquals("Z:\\jackcess_test\\linkeeTest.accdb", tmd.getLinkedDbName());
  809. }
  810. names.add(tmd.getName());
  811. }
  812. assertEquals(new HashSet<>(Arrays.asList("Table1", "Table2")),
  813. names);
  814. }
  815. }
  816. public void testTableDates() throws Exception {
  817. for (final TestDB testDB : SUPPORTED_DBS_TEST_FOR_READ) {
  818. Table table = open(testDB).getTable("Table1");
  819. String expectedCreateDate = null;
  820. String expectedUpdateDate = null;
  821. if(testDB.getExpectedFileFormat() == FileFormat.V1997) {
  822. expectedCreateDate = "2010-03-05T14:48:26.420";
  823. expectedUpdateDate = "2010-03-05T14:48:26.607";
  824. } else {
  825. expectedCreateDate = "2004-05-28T17:51:48.701";
  826. expectedUpdateDate = "2006-07-24T09:56:19.701";
  827. }
  828. assertEquals(expectedCreateDate, table.getCreatedDate().toString());
  829. assertEquals(expectedUpdateDate, table.getUpdatedDate().toString());
  830. }
  831. }
  832. public void testBrokenIndex() throws Exception {
  833. TestDB testDb = TestDB.getSupportedForBasename(Basename.TEST).get(0);
  834. try (Database db = new DatabaseBuilder(testDb.getFile())
  835. .setReadOnly(true).setIgnoreBrokenSystemCatalogIndex(true).open()) {
  836. Table test = db.getTable("Table1");
  837. assertNotNull(test);
  838. verifyFinderType(db, "FallbackTableFinder");
  839. }
  840. try (Database db = openMem(testDb)) {
  841. Table test = db.getTable("Table1");
  842. assertNotNull(test);
  843. verifyFinderType(db, "DefaultTableFinder");
  844. }
  845. }
  846. private static void verifyFinderType(Database db, String clazzName)
  847. throws Exception{
  848. java.lang.reflect.Field f = db.getClass().getDeclaredField("_tableFinder");
  849. f.setAccessible(true);
  850. Object finder = f.get(db);
  851. assertNotNull(finder);
  852. assertEquals(clazzName, finder.getClass().getSimpleName());
  853. }
  854. private static void checkRawValue(String expected, Object val)
  855. {
  856. if(expected != null) {
  857. assertTrue(ColumnImpl.isRawData(val));
  858. assertEquals(expected, val.toString());
  859. } else {
  860. assertNull(val);
  861. }
  862. }
  863. }