Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/adriangb/pgpq
/ functions
Functions
286 in github.com/adriangb/pgpq
⨍
Functions
286
◇
Types & classes
130
↓ 194 callers
Function
run_test_case
(case: &str)
core/tests/integration_tests.rs:26
↓ 117 callers
Method
field
(&self)
core/src/encoders.rs:1468
↓ 27 callers
Method
into_pyobject
(self, py: Python<'py>)
py/src/encoders.rs:1179
↓ 20 callers
Method
schema
(&self)
py/src/lib.rs:97
↓ 18 callers
Method
name
(&self)
core/src/pg_schema.rs:74
↓ 12 callers
Method
value
(&self, row: usize)
core/src/encoders.rs:641
↓ 11 callers
Method
finish
(&mut self)
py/src/lib.rs:91
↓ 8 callers
Method
schema
(&self)
core/src/lib.rs:89
↓ 7 callers
Method
write_batch
(&mut self, py_batch: &Bound<'_, PyAny>)
py/src/lib.rs:79
↓ 7 callers
Method
write_header
(&mut self, py: Python)
py/src/lib.rs:75
↓ 4 callers
Method
__repr__
(&self, py: Python)
py/src/pg_schema.rs:158
↓ 4 callers
Function
copy_buffer_and_get_rows
( schema: PostgresSchema, buffer: bytes, dbconn: Connection )
py/test_pgpq/test_struct.py:119
↓ 4 callers
Function
parse_composite_value
Parse Postgres composite type (struct) or array to Python tuple/list.
py/test_pgpq/test_struct.py:31
↓ 4 callers
Method
py_repr
(&self, py: Python)
py/src/pg_schema.rs:196
↓ 3 callers
Method
ddl
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 callers
Method
ddl
(&self)
py/src/pg_schema.rs:182
↓ 3 callers
Method
encode
(&self, row: usize, buf: &mut BytesMut)
core/src/encoders.rs:333
↓ 3 callers
Method
write_footer
(&mut self, out: &mut BytesMut)
core/src/lib.rs:144
↓ 2 callers
Function
array_to_utf8_json_array
( py: Python, array: &Bound<'_, PyAny>, large: bool, )
json/src/lib.rs:14
↓ 2 callers
Function
bench
(batches: &Vec<RecordBatch>, schema: &Schema)
core/benches/yellow_cab_dataset.rs:48
↓ 2 callers
Function
build_encoders
( fields: &arrow_schema::Fields, )
core/src/lib.rs:32
↓ 2 callers
Function
copy_buffer_and_get_rows
( schema: PostgresSchema, buffer: bytes, dbconn: Connection )
py/test_pgpq/test_pgpq.py:37
↓ 2 callers
Function
get_start_end
(row: usize, col: usize, n_rows: usize, offsets: &[usize])
core/benches/experiments.rs:14
↓ 2 callers
Method
oid
(&self)
core/src/pg_schema.rs:52
↓ 2 callers
Function
read_batches
(file: PathBuf)
core/tests/integration_tests.rs:18
↓ 2 callers
Method
schema
(&self)
core/src/encoders.rs:1454
↓ 2 callers
Function
setup
(row_limit: Option<usize>)
core/benches/yellow_cab_dataset.rs:36
↓ 2 callers
Method
try_new
(&'b self, arr: &'a dyn Array)
core/src/encoders.rs:1432
↓ 2 callers
Method
write_batch
( &mut self, batch: &RecordBatch, buf: &mut BytesMut, )
core/src/lib.rs:107
↓ 2 callers
Method
write_header
(&mut self, out: &mut BytesMut)
core/src/lib.rs:99
↓ 1 callers
Method
byte_size_hint
(&self)
core/src/encoders.rs:345
↓ 1 callers
Function
downcast_checked
(arr: &'a dyn Array, field: &str)
core/src/encoders.rs:16
↓ 1 callers
Function
download_dataset
()
core/benches/yellow_cab_dataset.rs:16
↓ 1 callers
Method
infer_encoder
(py: Python, py_field: &Bound<'_, PyAny>)
py/src/lib.rs:43
↓ 1 callers
Function
make_test_data
()
core/src/lib.rs:162
↓ 1 callers
Method
new_with_encoders
( py: Python, py_schema: &Bound<'_, PyAny>, py_encoders: &Bound<'_, PyDict>, )
py/src/lib.rs:52
↓ 1 callers
Function
parse_row_value
(value, field)
py/test_pgpq/test_pgpq.py:86
↓ 1 callers
Function
pretty_print_diff
from https://github.com/mitsuhiko/similar/blob/main/examples/terminal.rs
core/tests/integration_tests.rs:1116
↓ 1 callers
Method
try_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
Function
benchmark_nyc_taxi_full
(c: &mut Criterion)
core/benches/yellow_cab_dataset.rs:66
Function
benchmark_nyc_taxi_small
(c: &mut Criterion)
core/benches/yellow_cab_dataset.rs:58
Function
benchmark_to_sql
(c: &mut Criterion)
core/benches/experiments.rs:169
Method
collect_types
Collect user-defined type DDLs and a mapping from column path to type name
core/src/pg_schema.rs:120
Function
columnar_vs_row_wise
(c: &mut Criterion)
core/benches/experiments.rs:19
Function
convert_arrow_date32_to_postgres_date
(_field: &str, date: i32)
core/src/encoders.rs:440
Function
convert_arrow_time_milliseconds_to_postgres_time
( _field: &str, time_ms: i32, )
core/src/encoders.rs:472
Function
convert_arrow_time_seconds_to_postgres_time
( _field: &str, time_s: i32, )
core/src/encoders.rs:459
Function
convert_arrow_timestamp_microseconds_to_pg_timestamp
( _field: &str, timestamp_us: i64, )
core/src/encoders.rs:356
Function
convert_arrow_timestamp_milliseconds_to_pg_timestamp
( _field: &str, timestamp_ms: i64, )
core/src/encoders.rs:370
Function
convert_arrow_timestamp_seconds_to_pg_timestamp
( _field: &str, timestamp_s: i64, )
core/src/encoders.rs:386
Function
dbconn
(postgres: Postgresql)
py/test_pgpq/test_struct.py:26
Function
dbconn
(postgres: Postgresql)
py/test_pgpq/test_pgpq.py:31
Function
direct_byte_access_vs_string_wrapped
(c: &mut Criterion)
core/benches/experiments.rs:251
Method
field_too_large
(field: &str, size: usize)
core/src/error.rs:46
Method
from
(value: pgpq::encoders::EncoderBuilder)
py/src/encoders.rs:865
Method
from
(val: UserDefined)
py/src/pg_schema.rs:188
Method
from_postgres_type
(tp: PostgresType, field: &Field)
core/src/encoders.rs:1192
Method
get_data_type
(&self, py: Python)
py/src/pg_schema.rs:376
Method
inner_encoder_builder
(&self)
core/src/encoders.rs:1474
Method
mismatched_column_type
( field: &str, expected: &str, actual: &DataType, )
core/src/error.rs:73
Method
new
(field: Arc<Field>)
core/src/encoders.rs:1411
Method
new
(py: Python, pyschema: &Bound<'_, PyAny>)
py/src/lib.rs:30
Method
new
(fields: Vec<Column>)
py/src/pg_schema.rs:155
Function
postgres
()
py/test_pgpq/test_struct.py:21
Function
postgres
()
py/test_pgpq/test_pgpq.py:23
Method
postgres_datatype
(&self)
core/src/encoders.rs:1204
Method
py_repr
(&self, py: Python)
py/src/encoders.rs:605
Method
size
(&self)
core/src/pg_schema.rs:30
Function
test_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
Function
test_basic_struct
Test encoding a basic struct with int and string fields.
py/test_pgpq/test_struct.py:135
Function
test_binary
()
core/tests/integration_tests.rs:192
Function
test_binary_nullable
()
core/tests/integration_tests.rs:352
Function
test_bool
()
core/tests/integration_tests.rs:57
Function
test_bool_nullable
()
core/tests/integration_tests.rs:217
Function
test_build_with_encoders
()
core/src/lib.rs:188
Function
test_column_properties
()
py/test_pgpq/test_pgpq.py:280
Function
test_custom_encoding
(dbconn: Connection)
py/test_pgpq/test_pgpq.py:241
Function
test_date32
()
core/tests/integration_tests.rs:172
Function
test_date32_nullable
()
core/tests/integration_tests.rs:332
Function
test_decimal128
()
core/tests/integration_tests.rs:122
Function
test_decimal128_nullable
()
core/tests/integration_tests.rs:282
Function
test_decimal32
()
core/tests/integration_tests.rs:112
Function
test_decimal32_nullable
()
core/tests/integration_tests.rs:272
Function
test_decimal64
()
core/tests/integration_tests.rs:117
Function
test_decimal64_nullable
()
core/tests/integration_tests.rs:277
Function
test_duration_ms
()
core/tests/integration_tests.rs:182
Function
test_duration_ms_nullable
()
core/tests/integration_tests.rs:342
Function
test_duration_s
()
core/tests/integration_tests.rs:187
Function
test_duration_s_nullable
()
core/tests/integration_tests.rs:347
Function
test_duration_us
()
core/tests/integration_tests.rs:177
Function
test_duration_us_nullable
()
core/tests/integration_tests.rs:337
Function
test_encode_record_batch
(dbconn: Connection, testcase: str)
py/test_pgpq/test_pgpq.py:65
Function
test_float32
()
core/tests/integration_tests.rs:102
Function
test_float32_nullable
()
core/tests/integration_tests.rs:262
Function
test_float64
()
core/tests/integration_tests.rs:107
Function
test_float64_nullable
()
core/tests/integration_tests.rs:267
next →
1–100 of 286, ranked by callers