feat: Add support for postgres 'point' type

Author: SindriFr

Cargo.toml

@@ -44,6 +44,7 @@ ipnetwork = { version = "0.20", default-features = false, optional = true }
 mac_address = { version = "1.1", default-features = false, optional = true }
 ordered-float = { version = "4.6", default-features = false, optional = true }
 itoa = { version = "1.0.15", optional = true }
+geo-types = { version = "0.7", default-features = false, optional = true }
 
 [dev-dependencies]
 sea-query = { path = ".", features = ["tests-cfg"] }
@@ -87,6 +88,7 @@ with-ipnetwork = ["ipnetwork"]
 with-mac_address = ["mac_address"]
 sqlx-utils = ["derive"]
 sea-orm = ["sea-query-derive"]
+with-postgres-point = ["dep:geo-types", "dep:postgres-types", "postgres-types/with-geo-types-0_7"]
 tests-cfg = []
 all-features = [
     "all-types",

sea-query-postgres/Cargo.toml

@@ -39,3 +39,4 @@ postgres-array = ["postgres-types/array-impls", "sea-query/postgres-array"]
 postgres-vector = ["sea-query/postgres-vector", "pgvector/postgres"]
 with-ipnetwork = ["postgres-types/with-cidr-0_2", "sea-query/with-ipnetwork", "ipnetwork", "cidr"]
 with-mac_address = ["postgres-types/with-eui48-1", "sea-query/with-mac_address", "mac_address", "eui48"]
+with-postgres-point = ["sea-query/with-postgres-point"]

sea-query-postgres/src/lib.rs

@@ -136,6 +136,8 @@ impl ToSql for PostgresValue {
                 use eui48::MacAddress;
                 v.map(|v| MacAddress::new(v.bytes())).to_sql(ty, out)
             }
+            #[cfg(feature = "with-postgres-point")]
+            Value::Point(v) => v.as_deref().to_sql(ty, out),
         }
     }
 

sea-query-sqlx/Cargo.toml

@@ -42,6 +42,7 @@ with-uuid = ["sqlx?/uuid", "sea-query/with-uuid", "uuid"]
 with-time = ["sqlx?/time", "sea-query/with-time", "time"]
 with-ipnetwork = ["sqlx?/ipnetwork", "sea-query/with-ipnetwork", "ipnetwork"]
 with-mac_address = ["sqlx?/mac_address", "sea-query/with-mac_address", "mac_address"]
+with-postgres-point = ["sea-query/with-postgres-point"]
 postgres-array = ["sea-query/postgres-array"]
 postgres-vector = ["sea-query/postgres-vector", "pgvector/sqlx"]
 runtime-async-std = ["sqlx?/runtime-async-std"]

sea-query-sqlx/src/sqlx_postgres.rs

@@ -129,6 +129,10 @@ impl sqlx::IntoArguments<'_, sqlx::postgres::Postgres> for SqlxValues {
                 Value::MacAddress(mac) => {
                     let _ = args.add(mac);
                 }
+                #[cfg(feature = "with-postgres-point")]
+                Value::Point(point) => {
+                    let _ = args.add(point.as_deref());
+                }
                 #[cfg(feature = "postgres-array")]
                 Value::Array(ty, v) => match ty {
                     ArrayType::Bool => {

src/backend/mysql/table.rs

@@ -132,6 +132,7 @@ impl TableBuilder for MysqlQueryBuilder {
             ColumnType::Inet => unimplemented!("Inet is not available in MySQL."),
             ColumnType::MacAddr => unimplemented!("MacAddr is not available in MySQL."),
             ColumnType::LTree => unimplemented!("LTree is not available in MySQL."),
+            ColumnType::Point => unimplemented!("Point is not available in MySQL."),
         }
         .unwrap();
 

src/backend/postgres/table.rs

@@ -113,6 +113,7 @@ impl TableBuilder for PostgresQueryBuilder {
             ColumnType::MacAddr => sql.write_str("macaddr"),
             ColumnType::Year => unimplemented!("Year is not available in Postgres."),
             ColumnType::LTree => sql.write_str("ltree"),
+            ColumnType::Point => sql.write_str("point"),
         }
         .unwrap()
     }

src/backend/query_builder.rs

@@ -1167,6 +1167,8 @@ pub trait QueryBuilder:
             Value::Array(_, None) => buf.write_str("NULL")?,
             #[cfg(feature = "postgres-vector")]
             Value::Vector(None) => buf.write_str("NULL")?,
+            #[cfg(feature = "with-postgres-point")]
+            Value::Point(None) => buf.write_str("NULL")?,
             Value::Bool(Some(b)) => buf.write_str(if *b { "TRUE" } else { "FALSE" })?,
             Value::TinyInt(Some(v)) => {
                 write_int(buf, *v);
@@ -1355,6 +1357,14 @@ pub trait QueryBuilder:
                 write!(buf, "{v}")?;
                 buf.write_str("'")?;
             }
+            #[cfg(feature = "with-postgres-point")]
+            Value::Point(Some(v)) => {
+                buf.write_str("'(")?;
+                write!(buf, "{}", v.x())?;
+                buf.write_str(",")?;
+                write!(buf, "{}", v.y())?;
+                buf.write_str(")'")?;
+            }
         };
 
         Ok(())

src/backend/sqlite/table.rs

@@ -195,6 +195,7 @@ impl SqliteQueryBuilder {
             ColumnType::Bit(_) => unimplemented!("Bit is not available in Sqlite."),
             ColumnType::VarBit(_) => unimplemented!("VarBit is not available in Sqlite."),
             ColumnType::LTree => unimplemented!("LTree is not available in Sqlite."),
+            ColumnType::Point => unimplemented!("Point is not available in Sqlite."),
         }
         .unwrap()
     }

src/table/column.rs

@@ -72,6 +72,7 @@ impl From<&mut ColumnDef> for ColumnDef {
 /// | Inet                  | N/A               | inet                        | N/A                          |
 /// | MacAddr               | N/A               | macaddr                     | N/A                          |
 /// | LTree                 | N/A               | ltree                       | N/A                          |
+/// | Point                 | N/A               | point                       | N/A                          |
 #[non_exhaustive]
 #[derive(Debug, Clone)]
 pub enum ColumnType {
@@ -117,6 +118,7 @@ pub enum ColumnType {
     Inet,
     MacAddr,
     LTree,
+    Point,
 }
 
 /// Length for var-char/binary; default to 255