Repository URL to install this package:
Êþº¾ 4¾ i ! "# $ %& '( ) *+ ,-./ 01 23 45 67 d8 09 4: k; 2< 4= >? 0@A &BC (D.E >F 2GH -I 4J (KL 1M @N KO 4P QR S T UV.W 6XY <Z[ >\] >^ >_ `a <b 4c i Hjkl Hmno p Kq rs tu iw Hx yz{ i t i t t d 8 k t U ^ ¡ k¢ U£ U¤ @^¥¦ i§ «¥¬ 4 H®¯°±³ ¶ ·¸¹ »¼ ½ 2¾ ¿À.ÁÂÃÂÄÂ@ 2@.ÅÆ É ÊË Ì 4Í O Î ÏÐ 8.Ñ 6ÒÓ @_zÔÕ Ø HÙÚ ÛÜÝÞß iàáâ quirks <Lorg/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks; database )Lorg/apache/arrow/adbc/core/AdbcDatabase; connection +Lorg/apache/arrow/adbc/core/AdbcConnection; allocator )Lorg/apache/arrow/memory/BufferAllocator; util 4Lorg/apache/arrow/adbc/driver/testsuite/SqlTestUtil; tableName Ljava/lang/String; mainTable dependentTable <init> ()V Code LineNumberTable LocalVariableTable this GLorg/apache/arrow/adbc/driver/testsuite/AbstractConnectionMetadataTest; beforeEach Exceptionsã RuntimeVisibleAnnotations "Lorg/junit/jupiter/api/BeforeEach; afterEach !Lorg/junit/jupiter/api/AfterEach; getInfo reader )Lorg/apache/arrow/vector/ipc/ArrowReader; StackMapTableâäA Lorg/junit/jupiter/api/Test; getInfoByCode root *Lorg/apache/arrow/vector/VectorSchemaRoot; getObjectsConstraints constraints Ljava/util/List; #Lorg/apache/arrow/vector/util/Text; i I dbSchemas ,Lorg/apache/arrow/vector/complex/ListVector; dbSchemaTables tables .Lorg/apache/arrow/vector/complex/StructVector; tableNames 'Lorg/apache/arrow/vector/VarCharVector; tableConstraints schema +Lorg/apache/arrow/vector/types/pojo/Schema; tableFound Z LocalVariableTypeTable 6Ljava/util/List<Ljava/util/Map<Ljava/lang/String;*>;>;¯Y[]n getObjectsColumns columns tableColumns getObjectsCatalogs %Lorg/apache/arrow/vector/FieldVector; getObjectsCatalogsPattern getObjectsDbSchemas getObjectsTables getTableSchema stmt *Lorg/apache/arrow/adbc/core/AdbcStatement;åæ getTableSchemaDoesNotExist thrown *Lorg/apache/arrow/adbc/core/AdbcException; getTableTypes types tableTypes $Ljava/util/List<Ljava/lang/String;>;ç #lambda$getTableSchemaDoesNotExist$7 lambda$getObjectsColumns$6 O(Lorg/apache/arrow/vector/types/pojo/Field;)Lorg/apache/arrow/vector/util/Text; field *Lorg/apache/arrow/vector/types/pojo/Field; lambda$getObjectsConstraints$5 lambda$getObjectsConstraints$4 (Ljava/util/Map;)Z c Ljava/util/Map; lambda$getObjectsConstraints$3 lambda$getObjectsConstraints$2 lambda$getObjectsConstraints$1 lambda$getObjectsConstraints$0 SourceFile #AbstractConnectionMetadataTest.java ¼ ½ ® ¯ 2Must initialize quirks in subclass with @BeforeAllèéê %org/apache/arrow/memory/RootAllocator ´ µëìí ° ±îïð ² ³ 2org/apache/arrow/adbc/driver/testsuite/SqlTestUtil ¼ñ ¶ · fooòó ¸ ¹ product º ¹ sale » ¹ôõ java/lang/AutoCloseableö÷øù Êúäûüåýþÿ ä ÷ ½ java/lang/Throwable 'org/apache/arrow/adbc/core/AdbcInfoCode Ê #org/apache/arrow/vector/UInt4Vector 0org/apache/arrow/vector/complex/DenseUnionVector !"#$%&'(*+,-. ä *org/apache/arrow/vector/complex/ListVector/0 ,org/apache/arrow/vector/complex/StructVector12 %org/apache/arrow/vector/VarCharVector3456789 : BootstrapMethods;<= >?@A org/assertj/core/api/ListAssert constraint_nameBC !org/apache/arrow/vector/util/Text table_pkDó ¼õEFGHIJK constraint_column_namesLCMNçOPQRSTUVWXYZ[\ java/lang/Iterable]^_`a SALE_PRODUCT_FK product_id constraint_column_usagebcde !org/assertj/core/api/ObjectAssert fk_tableBfg Table FOO exists in metadata java/lang/Objecthi *org/assertj/core/api/AbstractBooleanAssertj% column_namek ordinal_positionlmnop+qrst u+v+wxyz{| 3S}~ o )org/apache/arrow/vector/types/pojo/Schema (org/apache/arrow/vector/types/pojo/Field INTS 0org/apache/arrow/vector/types/pojo/ArrowType$Int Int InnerClasses ¼ STRS 1org/apache/arrow/vector/types/pojo/ArrowType$Utf8 Utf8b ¼æ ö (org/apache/arrow/adbc/core/AdbcException ½ -org/assertj/core/api/AbstractComparableAssert ¡¢ þú£ ä java/util/ArrayList¤< table C8>¥¦A DOESNOTEXIST§ constraint_type¨©Q UNIQUEª< PRIMARY KEY Eorg/apache/arrow/adbc/driver/testsuite/AbstractConnectionMetadataTest java/lang/Exception 'org/apache/arrow/vector/ipc/ArrowReader (org/apache/arrow/vector/VectorSchemaRoot (org/apache/arrow/adbc/core/AdbcStatement java/util/List #org/apache/arrow/util/Preconditions checkNotNull 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :org/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks initDatabase T(Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/adbc/core/AdbcDatabase; 'org/apache/arrow/adbc/core/AdbcDatabase connect -()Lorg/apache/arrow/adbc/core/AdbcConnection; ?(Lorg/apache/arrow/adbc/driver/testsuite/SqlValidationQuirks;)V caseFoldTableName &(Ljava/lang/String;)Ljava/lang/String; cleanupTable (Ljava/lang/String;)V $org/apache/arrow/util/AutoCloseables close ([Ljava/lang/AutoCloseable;)V )org/apache/arrow/adbc/core/AdbcConnection +()Lorg/apache/arrow/vector/ipc/ArrowReader; getVectorSchemaRoot ,()Lorg/apache/arrow/vector/VectorSchemaRoot; getSchema -()Lorg/apache/arrow/vector/types/pojo/Schema; org/assertj/core/api/Assertions assertThat 7(Ljava/lang/Object;)Lorg/assertj/core/api/ObjectAssert; *org/apache/arrow/adbc/core/StandardSchemas GET_INFO_SCHEMA isEqualTo 9(Ljava/lang/Object;)Lorg/assertj/core/api/AbstractAssert; loadNextBatch ()Z /(Z)Lorg/assertj/core/api/AbstractBooleanAssert; isTrue .()Lorg/assertj/core/api/AbstractBooleanAssert; getRowCount ()I /(I)Lorg/assertj/core/api/AbstractIntegerAssert; *org/assertj/core/api/AbstractIntegerAssert isGreaterThan addSuppressed (Ljava/lang/Throwable;)V DRIVER_NAME )Lorg/apache/arrow/adbc/core/AdbcInfoCode; U([Lorg/apache/arrow/adbc/core/AdbcInfoCode;)Lorg/apache/arrow/vector/ipc/ArrowReader; getVector ((I)Lorg/apache/arrow/vector/FieldVector; getObject (I)Ljava/lang/Integer; A(Ljava/lang/Integer;)Lorg/assertj/core/api/AbstractIntegerAssert; getValue getVarCharVector *(B)Lorg/apache/arrow/vector/VarCharVector; &(I)Lorg/apache/arrow/vector/util/Text; toString ()Ljava/lang/String; ?(Ljava/lang/String;)Lorg/assertj/core/api/AbstractStringAssert; )org/assertj/core/api/AbstractStringAssert isNotEmpty 3()Lorg/assertj/core/api/AbstractCharSequenceAssert; ingestTableWithConstraints (Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/core/AdbcConnection;Ljava/lang/String;)Lorg/apache/arrow/vector/types/pojo/Schema; %ingestTablesWithReferentialConstraint {(Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/core/AdbcConnection;Ljava/lang/String;Ljava/lang/String;)V 9org/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth GetObjectsDepth ALL ;Lorg/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth; getObjects Á(Lorg/apache/arrow/adbc/core/AdbcConnection$GetObjectsDepth;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;Ljava/lang/String;)Lorg/apache/arrow/vector/ipc/ArrowReader; GET_OBJECTS_SCHEMA getDataVector '()Lorg/apache/arrow/vector/FieldVector; getVectorById ((I)Lorg/apache/arrow/vector/ValueVector; getValueCount isNull (I)Z java/lang/String equalsIgnoreCase (Ljava/lang/String;)Z (I)Ljava/util/List; 3(Ljava/util/List;)Lorg/assertj/core/api/ListAssert; «¬ (Ljava/lang/Object;)Z test ()Ljava/util/function/Predicate; filteredOn M(Ljava/util/function/Predicate;)Lorg/assertj/core/api/AbstractIterableAssert; extracting =(Ljava/lang/String;)Lorg/assertj/core/api/AbstractListAssert; caseFoldColumnName java/util/Collections singletonList $(Ljava/lang/Object;)Ljava/util/List; 'org/assertj/core/api/AbstractListAssert #containsExactlyInAnyOrderElementsOf C(Ljava/lang/Iterable;)Lorg/assertj/core/api/AbstractIterableAssert; ® flatExtracting getFields ()Ljava/util/List; stream ()Ljava/util/stream/Stream; &(Ljava/lang/Object;)Ljava/lang/Object; ¯ apply ()Ljava/util/function/Function; java/util/stream/Stream map 8(Ljava/util/function/Function;)Ljava/util/stream/Stream; java/util/stream/Collectors toList ()Ljava/util/stream/Collector; collect 0(Ljava/util/stream/Collector;)Ljava/lang/Object; ° hasSize 0(I)Lorg/assertj/core/api/AbstractIterableAssert; ± ² asList +()Lorg/assertj/core/api/AbstractListAssert; first '()Lorg/assertj/core/api/AbstractAssert; ?(Ljava/lang/String;)Lorg/assertj/core/api/AbstractObjectAssert; )org/assertj/core/api/AbstractObjectAssert describedAs 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/Object; ingestTableIntsStrs ³ java/lang/Integer valueOf containsExactlyInAnyOrder B([Ljava/lang/Object;)Lorg/assertj/core/api/AbstractIterableAssert; CATALOGS #org/apache/arrow/vector/FieldVector getNullCount defaultCatalog isFalse DB_SCHEMAS TABLES java/util/stream/IntStream range (II)Ljava/util/stream/IntStream; getClass ()Ljava/lang/Class; (I)Ljava/lang/Object; I(Lorg/apache/arrow/vector/VarCharVector;)Ljava/util/function/IntFunction; mapToObj ;(Ljava/util/function/IntFunction;)Ljava/util/stream/Stream; <(Ljava/util/stream/Stream;)Lorg/assertj/core/api/ListAssert; containsAnyOf ,org/apache/arrow/vector/types/pojo/ArrowType (IZ)V nullable l(Ljava/lang/String;Lorg/apache/arrow/vector/types/pojo/ArrowType;)Lorg/apache/arrow/vector/types/pojo/Field; java/util/Arrays %([Ljava/lang/Object;)Ljava/util/List; (Ljava/lang/Iterable;)V create (Lorg/apache/arrow/vector/types/pojo/Schema;Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/vector/VectorSchemaRoot; )org/apache/arrow/adbc/core/BulkIngestMode CREATE +Lorg/apache/arrow/adbc/core/BulkIngestMode; bulkIngest i(Ljava/lang/String;Lorg/apache/arrow/adbc/core/BulkIngestMode;)Lorg/apache/arrow/adbc/core/AdbcStatement; bind -(Lorg/apache/arrow/vector/VectorSchemaRoot;)V executeUpdate´ UpdateResult 9()Lorg/apache/arrow/adbc/core/AdbcStatement$UpdateResult; c(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/arrow/vector/types/pojo/Schema; µ execute t(Lorg/apache/arrow/adbc/driver/testsuite/AbstractConnectionMetadataTest;)Lorg/junit/jupiter/api/function/Executable; org/junit/jupiter/api/Assertions assertThrows S(Ljava/lang/Class;Lorg/junit/jupiter/api/function/Executable;)Ljava/lang/Throwable; getStatus -()Lorg/apache/arrow/adbc/core/AdbcStatusCode; G(Ljava/lang/Comparable;)Lorg/assertj/core/api/AbstractComparableAssert; )org/apache/arrow/adbc/core/AdbcStatusCode NOT_FOUND +Lorg/apache/arrow/adbc/core/AdbcStatusCode; TABLE_TYPES_SCHEMA add 2(Ljava/lang/String;)Ljava/util/function/Predicate; anyMatch getName java/util/Map get equals¶·º 5org/apache/arrow/adbc/core/AdbcStatement$UpdateResult ½ "java/lang/invoke/LambdaMetafactory metafactory¼ Lookup Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;½ %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles! i ® ¯ ° ± ² ³ ´ µ ¶ · ¸ ¹ º ¹ » ¹ ¼ ½ ¾ / *· ± ¿ ; À Á  à ½ ¾ Ö ² ¸ W*» Y· µ *² *´ ¶ µ **´ ¹ µ *» Y² · µ *² ¶ µ *² ¶ µ *² ¶ µ ² *´ ¶ ² *´ ¶ ² *´ ¶ ± ¿ 2 I J K " L / M = N I O U P a R k S u T U À Á Â Ä Å Æ Ç È ½ ¾ u ;² *´ ¶ ² *´ ¶ ² *´ ¶ ½ Y*´ SY*´ SY*´ S¸ ± ¿ Y Z [ \ : ] À ; Á Â Ä Å Æ É Ê ½ ¾ B *´ ¹ LM+¶ ¶ ¸ ² ¶ W+¶ ¸ ¶ !W+¶ ¶ "¸ #¶ $W+Æ F,Æ +¶ %§ ;N,-¶ '§ 2+¶ %§ +N-M-¿:+Æ ,Æ +¶ %§ :,¶ '§ +¶ %¿± ? C F &