MCPcopy Create free account

hub / github.com/adriangb/pgpq / functions

Functions286 in github.com/adriangb/pgpq

↓ 194 callersFunctionrun_test_case
(case: &str)
core/tests/integration_tests.rs:26
↓ 117 callersMethodfield
(&self)
core/src/encoders.rs:1468
↓ 27 callersMethodinto_pyobject
(self, py: Python<'py>)
py/src/encoders.rs:1179
↓ 20 callersMethodschema
(&self)
py/src/lib.rs:97
↓ 18 callersMethodname
(&self)
core/src/pg_schema.rs:74
↓ 12 callersMethodvalue
(&self, row: usize)
core/src/encoders.rs:641
↓ 11 callersMethodfinish
(&mut self)
py/src/lib.rs:91
↓ 8 callersMethodschema
(&self)
core/src/lib.rs:89
↓ 7 callersMethodwrite_batch
(&mut self, py_batch: &Bound<'_, PyAny>)
py/src/lib.rs:79
↓ 7 callersMethodwrite_header
(&mut self, py: Python)
py/src/lib.rs:75
↓ 4 callersMethod__repr__
(&self, py: Python)
py/src/pg_schema.rs:158
↓ 4 callersFunctioncopy_buffer_and_get_rows
( schema: PostgresSchema, buffer: bytes, dbconn: Connection )
py/test_pgpq/test_struct.py:119
↓ 4 callersFunctionparse_composite_value
Parse Postgres composite type (struct) or array to Python tuple/list.
py/test_pgpq/test_struct.py:31
↓ 4 callersMethodpy_repr
(&self, py: Python)
py/src/pg_schema.rs:196
↓ 3 callersMethodddl
Generate DDL for creating the table and any required types. If `temp_table` is true, creates a TEMP TABLE, otherwise a regular TABLE.
core/src/pg_schema.rs:118
↓ 3 callersMethodddl
(&self)
py/src/pg_schema.rs:182
↓ 3 callersMethodencode
(&self, row: usize, buf: &mut BytesMut)
core/src/encoders.rs:333
↓ 3 callersMethodwrite_footer
(&mut self, out: &mut BytesMut)
core/src/lib.rs:144
↓ 2 callersFunctionarray_to_utf8_json_array
( py: Python, array: &Bound<'_, PyAny>, large: bool, )
json/src/lib.rs:14
↓ 2 callersFunctionbench
(batches: &Vec<RecordBatch>, schema: &Schema)
core/benches/yellow_cab_dataset.rs:48
↓ 2 callersFunctionbuild_encoders
( fields: &arrow_schema::Fields, )
core/src/lib.rs:32
↓ 2 callersFunctioncopy_buffer_and_get_rows
( schema: PostgresSchema, buffer: bytes, dbconn: Connection )
py/test_pgpq/test_pgpq.py:37
↓ 2 callersFunctionget_start_end
(row: usize, col: usize, n_rows: usize, offsets: &[usize])
core/benches/experiments.rs:14
↓ 2 callersMethodoid
(&self)
core/src/pg_schema.rs:52
↓ 2 callersFunctionread_batches
(file: PathBuf)
core/tests/integration_tests.rs:18
↓ 2 callersMethodschema
(&self)
core/src/encoders.rs:1454
↓ 2 callersFunctionsetup
(row_limit: Option<usize>)
core/benches/yellow_cab_dataset.rs:36
↓ 2 callersMethodtry_new
(&'b self, arr: &'a dyn Array)
core/src/encoders.rs:1432
↓ 2 callersMethodwrite_batch
( &mut self, batch: &RecordBatch, buf: &mut BytesMut, )
core/src/lib.rs:107
↓ 2 callersMethodwrite_header
(&mut self, out: &mut BytesMut)
core/src/lib.rs:99
↓ 1 callersMethodbyte_size_hint
(&self)
core/src/encoders.rs:345
↓ 1 callersFunctiondowncast_checked
(arr: &'a dyn Array, field: &str)
core/src/encoders.rs:16
↓ 1 callersFunctiondownload_dataset
()
core/benches/yellow_cab_dataset.rs:16
↓ 1 callersMethodinfer_encoder
(py: Python, py_field: &Bound<'_, PyAny>)
py/src/lib.rs:43
↓ 1 callersFunctionmake_test_data
()
core/src/lib.rs:162
↓ 1 callersMethodnew_with_encoders
( py: Python, py_schema: &Bound<'_, PyAny>, py_encoders: &Bound<'_, PyDict>, )
py/src/lib.rs:52
↓ 1 callersFunctionparse_row_value
(value, field)
py/test_pgpq/test_pgpq.py:86
↓ 1 callersFunctionpretty_print_diff
from https://github.com/mitsuhiko/similar/blob/main/examples/terminal.rs
core/tests/integration_tests.rs:1116
↓ 1 callersMethodtry_new
Creates a new writer which will write rows of the provided types to the provided sink.
core/src/lib.rs:43
Method__richcmp__
(&self, other: &Self, op: CompareOp, py: Python<'_>)
py/src/pg_schema.rs:164
Method__str__
(&self, py: Python)
py/src/pg_schema.rs:161
Function_arrow_json
(m: &Bound<'_, PyModule>)
json/src/lib.rs:83
Function_pgpq
(m: &Bound<'_, PyModule>)
py/src/lib.rs:103
Functionbenchmark_nyc_taxi_full
(c: &mut Criterion)
core/benches/yellow_cab_dataset.rs:66
Functionbenchmark_nyc_taxi_small
(c: &mut Criterion)
core/benches/yellow_cab_dataset.rs:58
Functionbenchmark_to_sql
(c: &mut Criterion)
core/benches/experiments.rs:169
Methodcollect_types
Collect user-defined type DDLs and a mapping from column path to type name
core/src/pg_schema.rs:120
Functioncolumnar_vs_row_wise
(c: &mut Criterion)
core/benches/experiments.rs:19
Functionconvert_arrow_date32_to_postgres_date
(_field: &str, date: i32)
core/src/encoders.rs:440
Functionconvert_arrow_time_milliseconds_to_postgres_time
( _field: &str, time_ms: i32, )
core/src/encoders.rs:472
Functionconvert_arrow_time_seconds_to_postgres_time
( _field: &str, time_s: i32, )
core/src/encoders.rs:459
Functionconvert_arrow_timestamp_microseconds_to_pg_timestamp
( _field: &str, timestamp_us: i64, )
core/src/encoders.rs:356
Functionconvert_arrow_timestamp_milliseconds_to_pg_timestamp
( _field: &str, timestamp_ms: i64, )
core/src/encoders.rs:370
Functionconvert_arrow_timestamp_seconds_to_pg_timestamp
( _field: &str, timestamp_s: i64, )
core/src/encoders.rs:386
Functiondbconn
(postgres: Postgresql)
py/test_pgpq/test_struct.py:26
Functiondbconn
(postgres: Postgresql)
py/test_pgpq/test_pgpq.py:31
Functiondirect_byte_access_vs_string_wrapped
(c: &mut Criterion)
core/benches/experiments.rs:251
Methodfield_too_large
(field: &str, size: usize)
core/src/error.rs:46
Methodfrom
(value: pgpq::encoders::EncoderBuilder)
py/src/encoders.rs:865
Methodfrom
(val: UserDefined)
py/src/pg_schema.rs:188
Methodfrom_postgres_type
(tp: PostgresType, field: &Field)
core/src/encoders.rs:1192
Methodget_data_type
(&self, py: Python)
py/src/pg_schema.rs:376
Methodinner_encoder_builder
(&self)
core/src/encoders.rs:1474
Methodmismatched_column_type
( field: &str, expected: &str, actual: &DataType, )
core/src/error.rs:73
Methodnew
(field: Arc<Field>)
core/src/encoders.rs:1411
Methodnew
(py: Python, pyschema: &Bound<'_, PyAny>)
py/src/lib.rs:30
Methodnew
(fields: Vec<Column>)
py/src/pg_schema.rs:155
Functionpostgres
()
py/test_pgpq/test_struct.py:21
Functionpostgres
()
py/test_pgpq/test_pgpq.py:23
Methodpostgres_datatype
(&self)
core/src/encoders.rs:1204
Methodpy_repr
(&self, py: Python)
py/src/encoders.rs:605
Methodsize
(&self)
core/src/pg_schema.rs:30
Functiontest_array_of_structs
Test encoding arrays of structs (composite_type[]). PostgreSQL fully supports arrays of composite types in COPY BINARY format. This test veri
py/test_pgpq/test_struct.py:277
Functiontest_basic_struct
Test encoding a basic struct with int and string fields.
py/test_pgpq/test_struct.py:135
Functiontest_binary
()
core/tests/integration_tests.rs:192
Functiontest_binary_nullable
()
core/tests/integration_tests.rs:352
Functiontest_bool
()
core/tests/integration_tests.rs:57
Functiontest_bool_nullable
()
core/tests/integration_tests.rs:217
Functiontest_build_with_encoders
()
core/src/lib.rs:188
Functiontest_column_properties
()
py/test_pgpq/test_pgpq.py:280
Functiontest_custom_encoding
(dbconn: Connection)
py/test_pgpq/test_pgpq.py:241
Functiontest_date32
()
core/tests/integration_tests.rs:172
Functiontest_date32_nullable
()
core/tests/integration_tests.rs:332
Functiontest_decimal128
()
core/tests/integration_tests.rs:122
Functiontest_decimal128_nullable
()
core/tests/integration_tests.rs:282
Functiontest_decimal32
()
core/tests/integration_tests.rs:112
Functiontest_decimal32_nullable
()
core/tests/integration_tests.rs:272
Functiontest_decimal64
()
core/tests/integration_tests.rs:117
Functiontest_decimal64_nullable
()
core/tests/integration_tests.rs:277
Functiontest_duration_ms
()
core/tests/integration_tests.rs:182
Functiontest_duration_ms_nullable
()
core/tests/integration_tests.rs:342
Functiontest_duration_s
()
core/tests/integration_tests.rs:187
Functiontest_duration_s_nullable
()
core/tests/integration_tests.rs:347
Functiontest_duration_us
()
core/tests/integration_tests.rs:177
Functiontest_duration_us_nullable
()
core/tests/integration_tests.rs:337
Functiontest_encode_record_batch
(dbconn: Connection, testcase: str)
py/test_pgpq/test_pgpq.py:65
Functiontest_float32
()
core/tests/integration_tests.rs:102
Functiontest_float32_nullable
()
core/tests/integration_tests.rs:262
Functiontest_float64
()
core/tests/integration_tests.rs:107
Functiontest_float64_nullable
()
core/tests/integration_tests.rs:267
next →1–100 of 286, ranked by callers