ChP<SSKrSSKJr SSKJr SSKrSSKrSSKrSSK J r \S5r SSjr SSjr SrS rS rS rS rSS jr\S5rg)N)contextmanager) lru_cache) GeoDataFramec#f# SSKJnJn [X5(a8UR 5(dUR 5 Uv SSS5 gUv g[X5(aUR 5nUv SSS5 g[ SU35e!,(df  g=f!,(df  g=f7f)a Yield a connection within a transaction context. Engine.begin() returns a Connection with an implicit Transaction while Connection.begin() returns the Transaction. This helper will always return a Connection with an implicit (possibly nested) Transaction. Parameters ---------- conn_or_engine : Connection or Engine A sqlalchemy Connection or Engine instance Returns ------- Connection r) ConnectionEngineNzUnknown Connectable: )sqlalchemy.engine.baserr isinstancein_transactionbegin ValueError)conn_or_enginerrconns cC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\geopandas/io/sql.py _get_connr s$:.--,,..%%'$$('! N + +  ! ! #tJ$ #00@ABB(' $ #s5>B1B.B13B 8B1 BB1 B.*B1c\X;a[SUS35eURR5RU5S:a[SUS35eXR 5nUR (d[ RRnSn[URS[5(aUnOUnURU5=X'nUc[ R"URS5nUS:waa[X85n U R (dU SR5n U S U3nO)S US US 3n [ R""U [$S S9 SU3n[-XUS9$![&R(R*a( SUS 3n [ R""U [$S S9 SU3nNOf=f)aTransform a pandas DataFrame into a GeoDataFrame. The column 'geom_col' must be a geometry column in WKB representation. To be used to convert df based on pd.read_sql to gdf. Parameters ---------- df : DataFrame pandas DataFrame with geometry column in WKB representation. geom_col : string, default 'geom' column name to convert to shapely geometries crs : pyproj.CRS, optional CRS to use for the returned GeoDataFrame. The value can be anything accepted by :meth:`pyproj.CRS.from_user_input() `, such as an authority string (eg "EPSG:4326") or a WKT string. If not set, tries to determine CRS from the SRID associated with the first geometry in the database, and assigns that to all geometries. con : sqlalchemy.engine.Connection or sqlalchemy.engine.Engine Active connection to the database to query. Returns ------- GeoDataFrame zQuery missing geometry column ''zDuplicate geometry column 'zC' detected in SQL query output. Onlyone geometry column is allowed.cP[RR[U5SS9$)z!Load from binary encoded as text.T)hex)shapelywkbloadsstr)xs rload_geom_text$_df_to_geodf..load_geom_textVs ;;$$SV$6 6r auth_name:zCould not find srid z+ in the spatial_ref_sys table. Trying epsg:z as a fallback. stacklevelzepsg:z[Could not find the spatial reference system table (spatial_ref_sys) in PostGIS.Trying epsg:)crsgeometry)r columnsto_listcountdropnaemptyrrrr iatbytesapplyget_srid_get_spatial_ref_sys_dfitemwarningswarn UserWarningpderrors DatabaseErrorr) dfgeom_colr$congeomsload_geom_bytesr load_geomsridspatial_ref_sys_dfr warning_msgs r _df_to_geodfr@.s2:8*AFGG zz!!(+a/)(4. .  L   !E ;;!++++( 7 eiilE * *'I&I${{955 u ;##EIIaL1Dqy-)@)K&.33$6{$C$H$H$J !* 1TF334&9++/&A$ ! k;1M %dVn h 77+yy..)''+fO= MM+{qI!$.C)s; E%%AF+*F+c ^^^Uc&[R"UTUUUUUS9n [U TTTS9$[R"UTUUUUUS9n UUU4SjU 5$)atReturn a GeoDataFrame corresponding to the result of the query string, which must contain a geometry column in WKB representation. It is also possible to use :meth:`~GeoDataFrame.read_file` to read from a database. Especially for file geodatabases like GeoPackage or SpatiaLite this can be easier. Parameters ---------- sql : string SQL query to execute in selecting entries from database, or name of the table to read from the database. con : sqlalchemy.engine.Connection or sqlalchemy.engine.Engine Active connection to the database to query. geom_col : string, default 'geom' column name to convert to shapely geometries crs : dict or str, optional CRS to use for the returned GeoDataFrame; if not set, tries to determine CRS from the SRID associated with the first geometry in the database, and assigns that to all geometries. chunksize : int, default None If specified, return an iterator where chunksize is the number of rows to include in each chunk. See the documentation for pandas.read_sql for further explanation of the following parameters: index_col, coerce_float, parse_dates, params, chunksize Returns ------- GeoDataFrame Examples -------- PostGIS >>> from sqlalchemy import create_engine # doctest: +SKIP >>> db_connection_url = "postgresql://myusername:mypassword@myhost:5432/mydatabase" >>> con = create_engine(db_connection_url) # doctest: +SKIP >>> sql = "SELECT geom, highway FROM roads" >>> df = geopandas.read_postgis(sql, con) # doctest: +SKIP SpatiaLite >>> sql = "SELECT ST_AsBinary(geom) AS geom, highway FROM roads" >>> df = geopandas.read_postgis(sql, con) # doctest: +SKIP ) index_col coerce_float parse_datesparams chunksizer8r$r9c3<># UHn[UTTTS9v M g7f)rGN)r@).0r7r9r$r8s r _read_postgis..s LXbLhCS ALs)r4read_sqlr@) sqlr9r8r$rBrCrDrErFr7 df_generators ``` r _read_postgisrO~syr [[  %# BsDD{{  %#  LX  rch[URRR55nSnUHnUcMSU;dMSnM [ U5S:Xa/U(aSnO'USc [ S5eUSR 5nOSn[URR5(aUS - nXB4$) aGGet basic geometry type of a GeoDataFrame. See more info from: https://geoalchemy-2.readthedocs.io/en/latest/types.html#geoalchemy2.types._GISType Following rules apply: - if geometries all share the same geometry-type, geometries are inserted with the given GeometryType with following types: - Point, LineString, Polygon, MultiPoint, MultiLineString, MultiPolygon, GeometryCollection. - LinearRing geometries will be converted into LineString -objects. - in all other cases, geometries will be inserted with type GEOMETRY: - a mix of Polygons and MultiPolygons in GeoSeries - a mix of Points and LineStrings in GeoSeries - geometry is of type GeometryCollection, such as GeometryCollection([Point, LineStrings]) - if any of the geometries has Z-coordinate, all records will be written with 3D. F LinearRingTr LINESTRINGrz No valid geometries in the data.GEOMETRYZ) listr% geom_typeuniquelenr upperanyhas_z)gdf geom_types has_curvegttarget_geom_types r_get_geometry_typeras(cll,,3356JI :  R I   :! + !}$ !CDD#-a=#6#6#8 % 3<<  C  &&rcfSnSnURbVSHNnURRUS9nUb O2URRSUS9nUcM@[US5n O UcS n[ R "U[SS 9 U$![a [ R "U[SS 9 NGf=f) z6Get EPSG code from CRS if available. If not, return 0.NzNCould not parse CRS from the GeoDataFrame. Inserting data without defined CRS.)dF)min_confidenceESRI)rrfrr"r)r$to_epsg to_authorityint Exceptionr1r2r3)r\r=r? confidence auth_srids r_get_srid_from_crsros DX ww B+ wwjA#GG00$Z1 (y|,D, | k;1= K B MM+{q A Bs""B B B %B $B0/B0c^SSKJm URS:HnURX!4R U4Sj5URX!4'U$)Nr) LineStringrQc>T"U5$)N)geomrqs r3_convert_linearring_to_linestring..)s Z%r)shapely.geometryrqrVlocr-)r\ geom_namemaskrqs @r!_convert_linearring_to_linestringr{!sF+ ==L (D"wwt7==% CGGDO Jrc[R"[R"XRRUS9SSS9n[ R "USS9nX4U'U$)zConvert geometries to ewkb.)r=T)r include_sridF)copy)rto_wkbset_sridvalues_datar4 DataFrame)r\ryr=r:r7s r_convert_to_ewkbr.sR NN..444@  E c &ByM IrcSSKnSSKnUR5nURU5nUR U5 UR S5 SR SU55nURn SURRSURRSUS3n U R5n [U S5(aT[U R5(a:U RU 5n U RUR!55 SSS5 OU R#X5 SSS5 g!,(df  N=f!,(df  g=f) Nrz, c3.# UH nSUS3v M g7f)"Nrs)rIks rrJ$_psql_insert_copy..Gs/$Q!A3a$szCOPY "z"."z" (z) FROM STDIN WITH CSVr~)csvioStringIOwriter writerowsseekjoin connectiontableschemanamecursorhasattrcallabler~writeread copy_expert) tblrkeys data_iterrrs_bufrr& dbapi_connrMcurr~s r_psql_insert_copyr>s KKME ZZ F Y JJqMii/$//GJ !!"#ciinn%5S AVW     3  HSXX$6$6#$ 5::<( OOC '    s$4=E1 D4E4 E >E Ec SSKJn SSKJn UR 5nUR Rn [U5n [U5upUb U "XS9X'OX"XS90nU(a [X 5n[X U 5nUbUnOSnUS:Xa[U5nURRUX5(aLURU "S US US U S 355R!5SnUU :waS US U S3n[#U5eSSS5 [U5nUR%UUUUUUUU[&S9 SSS5 g![a [ S5ef=f!,(df  NW=f!,(df  g=f)a Upload GeoDataFrame into PostGIS database. This method requires SQLAlchemy and GeoAlchemy2, and a PostgreSQL Python driver (e.g. psycopg2) to be installed. Parameters ---------- name : str Name of the target table. con : sqlalchemy.engine.Connection or sqlalchemy.engine.Engine Active connection to the PostGIS database. if_exists : {'fail', 'replace', 'append'}, default 'fail' How to behave if the table already exists: - fail: Raise a ValueError. - replace: Drop the table before inserting new values. - append: Insert new values to the existing table. schema : string, optional Specify the schema. If None, use default schema: 'public'. index : bool, default True Write DataFrame index as a column. Uses *index_label* as the column name in the table. index_label : string or sequence, default None Column label for index column(s). If None is given (default) and index is True, then the index names are used. chunksize : int, optional Rows will be written in batches of this size at a time. By default, all rows will be written at once. dtype : dict of column name to SQL type, default None Specifying the datatype for columns. The keys should be the column names and the values should be the SQLAlchemy types. Examples -------- >>> from sqlalchemy import create_engine # doctest: +SKIP >>> engine = create_engine("postgresql://myusername:mypassword@myhost:5432/mydatabase";) # doctest: +SKIP >>> gdf.to_postgis("my_table", engine) # doctest: +SKIP r)Geometry)textz,'to_postgis()' requires geoalchemy2 package.N) geometry_typer=publicappendzSELECT Find_SRID('z', 'z');z"The CRS of the target table (EPSG:z5) differs from the CRS of current GeoDataFrame (EPSG:z).)r if_existsindex index_labelrFdtypemethod) geoalchemy2r sqlalchemyr ImportErrorr~r%rrorar{rrdialect has_tableexecutefetchoner to_sqlr)r\rr9rrrrrFrrrryr=rr^ schema_namer target_sridmsgs r_write_postgisrVsjJ(# ((*C !!I c "D 2#6M #-KH=LM/? 34 0C   H s^z!!++JEE(00-k]$tfD SVWX(*Q $&<[MJFFJV2O%S/) 3:  #$   ] JHIIJ@^ s$ D<A.EE&<E E#& E4c8SU3n[R"X 5$)Nz9SELECT srid, auth_name FROM spatial_ref_sys WHERE srid = )r4rL)r9r=spatial_ref_sys_sqls rr/r/s& DD6J ;;* 00r)rtNN)rtNNTNNN)NfailFNNN)r1 contextlibr functoolsrpandasr4r shapely.wkb geopandasrrr@rOraror{rrrr/rsrrrs%"CC@M8f  S l,'^<   (8   q h 1 1r