Python SQL脚本仅将数据帧的最后一行插入SQL Server[pyodbc]

2024-04-25 12:50:21 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试将数据框导入Microsoft SQL Server。尽管如此,该命令是正确的,并且执行成功,当我在SQL server中选择表的前1000行时,只显示导入的数据帧的最后一行

我有最新版本的SQL Server(昨天下载)

你知道这是什么原因吗

SQL代码(存储过程)

USE [Movies_Dataset]
GO
/****** Object:  StoredProcedure [dbo].[store_genres]    Script Date: xxx ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO

ALTER PROCEDURE [dbo].[store_genres]
                                    @Movie_Title NVARCHAR(MAX), 
                                    @Genres NVARCHAR(MAX)
  AS
  BEGIN
        DROP TABLE IF EXISTS [dbo].[table_genres];
        CREATE TABLE [dbo].[table_genres]([@Movie_Title] NVARCHAR(MAX),
                                          [@Genres] NVARCHAR(MAX)
                                         )
        INSERT INTO [dbo].[table_genres]
        VALUES
             ( @Movie_Title,
               @Genres
             )
  END;

导入数据的Python脚本

connStr = pyodbc.connect("DRIVER={SQL Server Native Client 11.0};"
                         "SERVER=LAPTOP-IFTEP7AL;"
                         "DATABASE=Movies_Dataset;"
                         "Trusted_Connection=yes")

cursor = connStr.cursor()

delete_table =  """           
                        IF dbo.TableExists('table_genres') = 1
                             DELETE FROM table_genres     
                """

insert_values = """ 
                        EXEC [dbo].[store_genres] @Movie_Title = ?, @Genres = ?;
                """   

cursor.execute(delete_table)

for index, row in genres.iterrows():

    params = (row['title'], row['genres'])

    cursor.execute(insert_values, params)

connStr.commit()

cursor.close()

connStr.close()

我要导入的数据帧

enter image description here

SQL结果

enter image description here


Tags: 数据storegosqlservertitletablemovie
1条回答
网友
1楼 · 发布于 2024-04-25 12:50:21

I select the first 1000 rows of the table in SQL server only the last row of the imported dataframe is shown.

因为存储过程每次插入行之前都会删除表

所以不要那样做。也不要在列名中使用@。这只适用于参数、参数和局部变量

例如:

USE [Movies_Dataset]
GO

SET QUOTED_IDENTIFIER ON
GO
        DROP TABLE IF EXISTS [dbo].[table_genres];
        CREATE TABLE [dbo].[table_genres]([Movie_Title] NVARCHAR(MAX),
                                          [Genres] NVARCHAR(MAX)
                                         )

GO
/****** Object:  StoredProcedure [dbo].[store_genres]    Script Date: xxx ******/
SET ANSI_NULLS ON
GO

CREATE OR ALTER PROCEDURE [dbo].[store_genres] 
                                    @Movie_Title NVARCHAR(MAX), 
                                    @Genres NVARCHAR(MAX)
  AS
  BEGIN
        INSERT INTO [dbo].[table_genres](Movie_Title,Genres)
        VALUES
             ( @Movie_Title,
               @Genres
             )
  END;

相关问题 更多 >