Python Web（Django）链接SQL SERVER

（开开心心每一天~ ---虫瘾师）

 

Python Web（Django） 与SQL SERVRE的链接————Come QQ群：607021567（里面有不少开源代码和资料，而且python的游戏也有）

（一）、SQL SERVER的基本介绍（简单）————SQL 是用于访问和处理数据库的标准的计算机语言。

（二）、Django框架——Django采用了MVC的软件设计模式，即模型M，视图V和控制器C。

 

一、SQL SERVER 基本结构

　　table---表：字段、记录；

　　 view---视图：是从一个或多个基本表中定义的虚表，至关于一个窗口，经过该窗口能够看到用户所须要的数据；

　　stored procedure---存储过程：存储过程的存在独立于表，用户能够运用存储过程来完善应用程序；

　　trigger---触发器：用户经过使用触发器来实现各类复杂的业务规则；

　　indexes---索引：用户和角色：用户是指对数据库具备必定权限的使用者，角色是一组具备相同权限的用户集合；

 

这里Python Web（Django）须要主要用到的是  stored procedure---存储过程 。

stored procedure---存储过程————存储过程是SQL语句和控制语句的预编译集合,保存在数据库中,能够调用执行,而且容许用户声明变量.逻辑控制语句以及其余强大的编程功能。

我会将项目中详细用到的内容都会写下来。

 

二、Django框架 基本结构

 ---->主项目文件夹

　　----->工程文件夹

　　　　主控文件： ----->settings.py ——主要控制你的静态文件，和python自带数据库，也可以使用它来链接数据库

　　　　　　　　　 ----->urls.py ——web前端经过后台须要访问的地址，而且静态文件的地址也是须要写在这里的 

　　　　　　　　　 ----->wsgi.py ——服务器管理处

　　------>templates ：模板文件夹，能够在建立一个脚本文件夹static

这里咱们不须要用python建立后自带的链接数据库文件，由于这样要考虑到没有用软件来建立项目的人，他们的文件位置也能够改变，可是项目文件夹必须有一个。

链接sql server 须要本身写py文件。

----先要知道SQL SERVER的存储过程和表的实例：

首先建立SQL SERVER 的数据库和表，我就随便建立一个了

　

create table table_1 ( id int primary key identity(1,1) not null, name varchar(50) not null, age int not null )

由于是随便建立的表，因此都是默认下去的！接下来，是对存储过程。

新建存储过程：

create proc xxxxx --存储过程名字 as select * FROM table_1 --SQL 语句 go

建立完以后，咱们的存储过程就能够根据咱们前端须要来修改了，好比若是咱们作个后台登陆，或者成绩查询，都须要上传学生id，而且每一次查询的信息能够放在存储过程的临时表内，也能够直接返回。

列：

USE [my_sp] GO /****** Object: StoredProcedure [dbo].[my_sp_py] Script Date: 05/18/2018 15:24:28 ******/ SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO ALTER proc [dbo].[my_sp_py] @userid int, @page int, @pagesize int as /* select * from table_1 */ SET NOCOUNT ON; declare @count int select @count =COUNT(*) from table_1 if @count > 0 begin create table #table --临时表的结构  ( id bigint, userid int, ctype nvarchar(30), Reduce nvarchar(10), num int, Remarks nvarchar(max), sum int, uptime datetime, ) declare @where_condition nvarchar(max) set @where_condition = '' if(@userid <>0) set @where_condition = @where_condition + ' and userid='+cast(@userid as varchar) declare @filedlist nvarchar(500) set @filedlist = 'id,userid,ctype,Reduce,num,Remark,sum,uptime' --须要insert 到表中的字段 declare @sql nvarchar(MAX) if @page>1 set @sql = 'SQL 语句' else set @sql = 'SQL 语句' --print @sql exec (@sql) --执行SQL 语句 select * from #table --返回的结果 end 

由于这个是页码和每一条数的控制，userid就是须要查询时候定义的id，到这里基本咱们的存储过程就写完了！接下来就是python 链接SQL SERVER 而且访问数据库中的数据，你能够点击这里看简便的处理 链接方式 

首先，咱们须要独立建立一个py文件，建立一个类 class sql_server:

MSSQL_INFO = {"hostname":"local","username":"local","password":"","dbname":"table_1"}

另外，由于web应用中能够使用多个sql,因此咱们把数据链接的文件放在一个单独的py文件内！

模块：pyodbc--数据库链接 建立sqlmb.py文件

strconn= 'DRIVER={SQL Server};SERVER='+sql_server.MSSQL_INFO.get("hostname")+';DATABASE='+sql_server.MSSQL_INFO.get("dbname")+';UID='+sql_server.MSSQL_INFO.get("username")+';PWD='+sql_server.MSSQL_INFO.get("password") db = pyodbc.connect(strconn) return db

数据链接就到这里已经成功一半了，接下来就是咱们项目中须要去访问数据库的数据了！

使用前要import 包名（sqlmb）

mssql_conn = sqlmb.mssqlserver_conn_db()
c = mssql_conn.cursor() c.execute("{call my_sp_py (?,?,?)}", (userid,page,pagesize)) q = c.fetchone() #fetchall全部数据 c.commit()

q就是数据库中所返回的数据，也就是select所返回的内容！好了，django与sql server的处理基本就是这些内容！下次再见！

def basicinfo(request): logininfo = checkLogin(request) if logininfo and logininfo.get('loginuserid') != None and logininfo.get('loginuserid')!="": mssql_conn = common.mssqlserver_conn_db() cs = mssql_conn.cursor() cs.execute("{call my_sp_py (?,?,?)}", userid,page,pagesize) q = cs.fetchone() cs.commit() if (q and len(q) > 0): if q[0] != 0: 　　a = list(q) c = [] for i in range(0, len(a)): if a[i] == None: a[i] = "" c.append(a[i]) else: c.append(a[i]) logininfo['myname'] = c[1] logininfo['companyname'] = c[2] logininfo['myphone'] = c[3] logininfo['faxnum'] = c[4] logininfo['post'] = c[5] logininfo['tradetype'] = c[6] logininfo['vip'] = c[7] logininfo['industry'] = c[8] logininfo['province'] = c[9] logininfo['city'] = c[10] logininfo['county'] = c[11] logininfo['useraddress'] = c[12] cs.execute("{call infosearch_list_py (?)}", logininfo.get('loginuserid')) q = cs.fetchone() cs.commit() if (q and len(q) > 0): if q[1]: logininfo['LastLoginIP'] = q[1] else: logininfo['LastLoginIP'] = 0 if q[2]: logininfo['LoginCount'] = q[2] else: logininfo['LoginCount'] = 0 if q[3]: logininfo['LastLoginTime'] = q[3].strftime('%Y-%m-%d %H:%M:%S') else: logininfo['LastLoginTime']=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time())) if q[4]: logininfo['lottery_num'] = q[4] else: logininfo['lottery_num'] = 0 if q[5]: logininfo['integral_num'] = q[5] else: logininfo['integral_num'] = 0 if q[6]: logininfo['indent_num'] = q[6] else: logininfo['indent_num'] = 0 if q[7]: logininfo['work_order_num'] = q[7] else: logininfo['work_order_num'] = 0 cs.close() mssql_conn.close() return render_to_response('template/user_basicinfo.html',logininfo) else: return HttpResponseRedirect('/signin')

 这里分享一个个人例子！