# Python Script to Connect to SQL Server and Retrieve Data From a Table
import sys
import pypyodbc
# Create a new database:
connection_str = """
Driver={SQL Server Native Client 11.0};
Server=localhost;
Database=master;
Trusted_Connection=yes;
"""
db_connection = pypyodbc.connect(connection_str)
db_connection.autocommit = True
db_cursor = db_connection.cursor()
sql_command = """
CREATE DATABASE MYDB
"""
try:
db_cursor.execute(sql_command)
except pypyodbc.ProgrammingError:
print("Database 'MYDB' already exists.")
db_connection.autocommit = False
db_cursor.close()
del db_cursor
db_connection.close()
# Connect a database.
connection_str = """
Driver={SQL Server Native Client 11.0};
Server=Localhost;
Database=MYDB;
Trusted_Connection=yes;
"""
db_connection = pypyodbc.connect(connection_str)
db_connection.autocommit = True
db_connection.autocommit = False
db_cursor = db_connection.cursor()
# Select rows from a table:
# 1) Select all columns of all rows:
sql_command = """
SELECT * FROM [ods].[MYTABLE]
"""
db_cursor.execute(sql_command)
rows = db_cursor.fetchall()
for row in rows:
userid, fname= row[0] ,row[1]
# Now print fetched result
print (userid,fname)
import sys
import pypyodbc
# Create a new database:
connection_str = """
Driver={SQL Server Native Client 11.0};
Server=localhost;
Database=master;
Trusted_Connection=yes;
"""
db_connection = pypyodbc.connect(connection_str)
db_connection.autocommit = True
db_cursor = db_connection.cursor()
sql_command = """
CREATE DATABASE MYDB
"""
try:
db_cursor.execute(sql_command)
except pypyodbc.ProgrammingError:
print("Database 'MYDB' already exists.")
db_connection.autocommit = False
db_cursor.close()
del db_cursor
db_connection.close()
# Connect a database.
connection_str = """
Driver={SQL Server Native Client 11.0};
Server=Localhost;
Database=MYDB;
Trusted_Connection=yes;
"""
db_connection = pypyodbc.connect(connection_str)
db_connection.autocommit = True
db_connection.autocommit = False
db_cursor = db_connection.cursor()
# Select rows from a table:
# 1) Select all columns of all rows:
sql_command = """
SELECT * FROM [ods].[MYTABLE]
"""
db_cursor.execute(sql_command)
rows = db_cursor.fetchall()
for row in rows:
userid, fname= row[0] ,row[1]
# Now print fetched result
print (userid,fname)
No comments:
Post a Comment