Repository URL to install this package:
Êþº¾ 4. a Ü Ý Þ ß à á Ü â ã ä å æ ç è é ê ë ì ã í î ï ð ¦ ã ñ ò ó ò ô õ ¨ ò ö ÷ ø ù ú ò û ü ã ý þ ÿ % % % & & & 3 3 3 > A Ü A! A"#$ ®% &' () *+ &, (-. 4 4 67 ® 8 4 4 < W Ü >?@ aA D EF ZG (HIJ cKL MN cO MP QRSTU VW XYZ[ \]^ (_ `a b]c ô 6d Ve fg hi j 6Oklm n *o 6pq 6r Vs tuv 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; schema32 +Lorg/apache/arrow/vector/types/pojo/Schema; schema64 <init> ()V Code LineNumberTable LocalVariableTable this >Lorg/apache/arrow/adbc/driver/testsuite/AbstractStatementTest; beforeEach Exceptionsw RuntimeVisibleAnnotations "Lorg/junit/jupiter/api/BeforeEach; afterEach !Lorg/junit/jupiter/api/AfterEach; bulkIngestAppend ints #Lorg/apache/arrow/vector/IntVector; strs 'Lorg/apache/arrow/vector/VarCharVector; &Lorg/apache/arrow/vector/BigIntVector; stmt *Lorg/apache/arrow/adbc/core/AdbcStatement; queryResultx QueryResult InnerClasses 6Lorg/apache/arrow/adbc/core/AdbcStatement$QueryResult; root64 *Lorg/apache/arrow/vector/VectorSchemaRoot; root32 StackMapTablevyzx Lorg/junit/jupiter/api/Test; bulkIngestAppendConflict root schema2 ï bulkIngestAppendNotFound e *Lorg/apache/arrow/adbc/core/AdbcException; bulkIngestCreateConflict executeSchema actualSchema name{ executeSchemaPrepared executeSchemaParams schema prepareQuery expectedSchema prepareQueryWithParametersNoOp param0 params paramsSchema prepareQueryWithParameters getParameterSchema lambda$bulkIngestAppend$3 W(Lorg/apache/arrow/vector/VectorSchemaRoot;Lorg/apache/arrow/vector/VectorSchemaRoot;)V data lambda$bulkIngestAppend$2 lambda$bulkIngestAppend$1 lambda$bulkIngestAppend$0 SourceFile AbstractStatementTest.java 2Must initialize quirks in subclass with @BeforeAll|}~ %org/apache/arrow/memory/RootAllocator 2org/apache/arrow/adbc/driver/testsuite/SqlTestUtil bulktable )org/apache/arrow/vector/types/pojo/Schema (org/apache/arrow/vector/types/pojo/Field java/lang/AutoCloseabley !org/apache/arrow/vector/IntVector %org/apache/arrow/vector/VarCharVector¡¢£¤¥¢ foo¦§¨{©ª£« asdf¬¢ $org/apache/arrow/vector/BigIntVector£®¯°±²³z´µ¶¹ java/lang/Throwableº»¼½ java/lang/StringBuilder SELECT * FROM ¾¿ÀÁÂÃÄÅÆÇÈÉÊËÌÍÎÏÐÑËÒ %org/assertj/core/api/ThrowingConsumer BootstrapMethodsÓÔÕµÖ×ØÙÚÛÜ°ÝÞß 1org/apache/arrow/vector/types/pojo/ArrowType$Utf8 Utf8àáâ (org/apache/arrow/adbc/core/AdbcExceptionãä <åæçèéêëËì %s java/lang/Objectíî -org/assertj/core/api/AbstractComparableAssertïðñòóôñõö STRS SELECT FROM Ä÷øùûüòýþ SELECT ? AS FOOÿ Ëò÷ ò SELECT * FROM %s WHERE INTS = ? !org/apache/arrow/vector/util/Text Ï Ó÷ò <org/apache/arrow/adbc/driver/testsuite/AbstractStatementTest java/lang/Exception 4org/apache/arrow/adbc/core/AdbcStatement$QueryResult (org/apache/arrow/vector/VectorSchemaRoot (org/apache/arrow/adbc/core/AdbcStatement java/lang/String #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; caseFoldColumnName -org/apache/arrow/vector/types/Types$MinorType MinorType INT /Lorg/apache/arrow/vector/types/Types$MinorType; getType 0()Lorg/apache/arrow/vector/types/pojo/ArrowType; nullable l(Ljava/lang/String;Lorg/apache/arrow/vector/types/pojo/ArrowType;)Lorg/apache/arrow/vector/types/pojo/Field; VARCHAR java/util/Arrays asList %([Ljava/lang/Object;)Ljava/util/List; (Ljava/lang/Iterable;)V BIGINT cleanupTable (Ljava/lang/String;)V $org/apache/arrow/util/AutoCloseables close ([Ljava/lang/AutoCloseable;)V create (Lorg/apache/arrow/vector/types/pojo/Schema;Lorg/apache/arrow/memory/BufferAllocator;)Lorg/apache/arrow/vector/VectorSchemaRoot; getVector ((I)Lorg/apache/arrow/vector/FieldVector; allocateNew (I)V setSafe (II)V setNull !java/nio/charset/StandardCharsets UTF_8 Ljava/nio/charset/Charset; getBytes (Ljava/nio/charset/Charset;)[B (I[B)V setRowCount (IJ)V )org/apache/arrow/adbc/core/BulkIngestMode CREATE +Lorg/apache/arrow/adbc/core/BulkIngestMode; )org/apache/arrow/adbc/core/AdbcConnection 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; addSuppressed (Ljava/lang/Throwable;)V createStatement ,()Lorg/apache/arrow/adbc/core/AdbcStatement; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; setSqlQuery executeQuery 8()Lorg/apache/arrow/adbc/core/AdbcStatement$QueryResult; getReader +()Lorg/apache/arrow/vector/ipc/ArrowReader; 'org/apache/arrow/vector/ipc/ArrowReader loadNextBatch ()Z org/assertj/core/api/Assertions assertThat /(Z)Lorg/assertj/core/api/AbstractBooleanAssert; *org/assertj/core/api/AbstractBooleanAssert isTrue .()Lorg/assertj/core/api/AbstractBooleanAssert; getVectorSchemaRoot ,()Lorg/apache/arrow/vector/VectorSchemaRoot; 7(Ljava/lang/Object;)Lorg/assertj/core/api/ObjectAssert; ! (Ljava/lang/Object;)V " acceptThrows S(Lorg/apache/arrow/vector/VectorSchemaRoot;)Lorg/assertj/core/api/ThrowingConsumer; # !org/assertj/core/api/ObjectAssert satisfiesAnyOf O([Lorg/assertj/core/api/ThrowingConsumer;)Lorg/assertj/core/api/AbstractAssert; APPEND $ % ,org/apache/arrow/vector/types/pojo/ArrowType java/util/Collections singletonList $(Ljava/lang/Object;)Ljava/util/List; getClass ()Ljava/lang/Class; execute W(Lorg/apache/arrow/adbc/core/AdbcStatement;)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; describedAs 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/Object; )org/apache/arrow/adbc/core/AdbcStatusCode NOT_FOUND +Lorg/apache/arrow/adbc/core/AdbcStatusCode; isEqualTo 9(Ljava/lang/Object;)Lorg/assertj/core/api/AbstractAssert; ALREADY_EXISTS ingestTableIntsStrs (Lorg/apache/arrow/memory/BufferAllocator;Lorg/apache/arrow/adbc/core/AdbcConnection;Ljava/lang/String;)Lorg/apache/arrow/vector/types/pojo/Schema; -()Lorg/apache/arrow/vector/types/pojo/Schema; 6org/apache/arrow/adbc/driver/testsuite/ArrowAssertions assertSchema SchemaAssert r(Lorg/apache/arrow/vector/types/pojo/Schema;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$SchemaAssert; Corg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$SchemaAssert Y(Ljava/lang/Object;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$SchemaAssert; prepare getFields ()Ljava/util/List; java/util/List size ()I /(I)Lorg/assertj/core/api/AbstractIntegerAssert; *org/assertj/core/api/AbstractIntegerAssert getSchema get (I)Ljava/lang/Object; isIn :([Ljava/lang/Object;)Lorg/assertj/core/api/AbstractAssert; assertField FieldAssert p(Lorg/apache/arrow/vector/types/pojo/Field;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$FieldAssert; Borg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$FieldAssert X(Ljava/lang/Object;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$FieldAssert; getRowCount format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; #org/apache/arrow/vector/FieldVector getObject isFalse isNull isNotNull '()Lorg/assertj/core/api/AbstractAssert; assertRoot VectorSchemaRootAssert {(Lorg/apache/arrow/vector/VectorSchemaRoot;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert; Morg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert c(Ljava/lang/Object;)Lorg/apache/arrow/adbc/driver/testsuite/ArrowAssertions$VectorSchemaRootAssert; #org/apache/arrow/vector/types/Types 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! a / *· ± 4 6 Ȳ ¸ W*» Y· µ *² *´ ¶ µ **´ ¹ µ *» Y² · µ *² ¶ µ *» Y½ Y² ¶ ² ¶ ¸ SY² ¶ ² ¶ ¸ S¸ · µ *» Y½ Y² ¶ ² ¶ ¸ SY² ¶ ² ¶ ¸ S¸ · µ ² *´ ¶ ± J C D E " F / G = H I I Y L m N v M z K O R § T ° S ´ Q ½ U Ç V È ¡ ¢ £ Y '² *´ ¶ ½ !Y*´ SY*´ SY*´ S¸ "± Z [ &