#!python2
#coding:gbk12

#!python3

py -2 -m pip install *****  #python2
py -3 -m pip install *****  #python3

"""
★类名称命名：
类总是使用驼峰格式命名，即所有单词首字母大写其余字母小写。
类名应该简明，精确，并足以从中理解类所完成的工作。
常见的一个方法是使用表示其类型或者特性的后缀，例如:SQLEngine ，MimeTypes
对于基类而言，可以使用一个 Base 或者 Abstract 前缀
不要滥用 *args 和 **kwargs，可能会破坏函数的健壮性
"""
# 变量命名总结：
# 1.单下划线开头变量：protected
# 2.双下划线开头变量：private
# 3.双下划线开头，双下划线结尾：系统内置变量
"""
单下划线开头变量
_xxx，单下划线开头的变量，标明是一个受保护(protected)的变量，原则上不允许直接访问，但外部类还是可以访问到这个变量。
这只是程序员之间的一个约定，用于警告说明这是一个私有变量，外部类不要去访问它。
print(stu._name) 当要输入_name时，pycharm不会进行_name的提示
print(stu.age) 当要显示age时，pycharm会进行age的提示
"""
class Student:
def __init__(self, name, sex):
self._name = name
self.sex = sex
stu = Student('zyf', 'Male')
print(stu._name) # 单下划线protected的变量，原则上不允许直接访问 输出：zyf
print(stu.sex) # age可以直接访问 输出：Male

"""
双下划线开头
__xxx，双下划线开头的，表示的是私有类型(private)的变量。
只能是允许这个类本身进行访问了, 连子类也不可以.
用于命名一个类属性（类变量）,调用时名字被改变
（在类Student内部，__name变成_Student__name,如 self._Student__name)
双下划线开头的实例变量是不是一定不能从外部访问呢？其实也不是。仍然可以通过_Student__name来访问__name变量：
"""
class Person:
def __init__(self, name):
self.__name = name
per = Person('zyf2')
print(per._Person__name) # 输出zyf2 但是无法直接访问__name

"""
双下划线开头，并且以双下划线结尾
__xxx__，以双下划线开头，并且以双下划线结尾的，是内置变量.
内置变量是可以直接访问的，不是 private 变量，如__init__，__import__或是__file__。
★不要自己定义这类变量
xxx_，单下划线结尾的变量一般只是为了避免与 Python 关键字的命名冲突
USER_CONSTANT，大写加下划线，对于不会发生改变的全局变量，使用大写加下划线
"""

# 函数命名总结：
# 1.私有方法：小写和一个前导下划线
# 2.特殊方法（魔术方法）：小写和两个前导下划线，两个后置下划线
# 3.函数参数：小写和下划线，缺省值等号两边无空格

"""
函数
总体而言应该使用，小写和下划线
私有方法 ： 小写和一个前导下划线
这里和私有变量一样，并不是真正的私有访问权限。
同时也应该注意一般函数不要使用两个前导下划线(当遇到两个前导下划线时，Python 的名称改编特性将发挥作用)。特殊函数后面会提及。
#特殊方法 ： 小写和两个前导下划线，两个后置下划线
#这种风格只应用于特殊函数，比如操作符重载等。
#函数参数 : 小写和下划线，缺省值等号两边无空格
"""
# 私有方法
class PrivateCase:
@staticmethod
def _secrete():
print(r"Don't test me")
priC = PrivateCase()
priC._secrete() # _secrete为protected member

# 特殊方法（魔术方法）
def __add__(self, other):
return int.__add__(other)

# 函数参数
def connect(self, user=None):
self._user = user

1.是否以start开头：str.startswith('start')
是否以end结尾：str.endswith('end')
是否全为字母或数字：str.isalnum()
是否全字母：str.isalpha()
是否全数字：str.isdigit()
是否全⼩写：str.islower()
是否全⼤写：str.isupper()
2.全部⼤写：str.upper()
全部⼩写：str.lower()
⼤⼩写互换：str.swapcase()
⾸字母⼤写，其余⼩写：str.capitalize()
⾸字母⼤写：str.title()
3.搜索指定字符串，没有返回-1：str.find('t')
指定起始位置搜索：str.find('t',start)
指定起始及结束位置搜索：str.find(’t',start,end)
从右边开始查找：str.rfind('t')
搜索到多少个指定字符串：str.count('t')
上⾯所有⽅法都可⽤index代替，不同的是使⽤
index查找不到会抛异常，⽽find返回-1
1. 替换old为new：str.replace('old','new')
替换指定次数的old为new：
str.replace(‘old','new',maxReplaceTimes)
2. 去两边空格：str.strip()
去左空格：str.lstrip()
去右空格：str.rstrip()
去两边字符串：str.strip(‘d’)
相应的也有lstrip，rstrip
3. str.join() ⽅法⽤于将序列中的元素以指
定的字符连接⽣成⼀个新的字符串。
s1.join(seq),s1=“-“,seq是你要连接的序列
4. print('Hi, %s, you have $%d.' % ('linda',
100000000))
print('Hello, {0}, 成绩提升了
{1:.1f}%'.format('⼩明', 17.125))

os.sep:取代操作系统特定的路径分隔符
os.name:指⽰你正在使⽤的⼯作平台。⽐如对于Windows，它是'nt'，⽽对于Linux/Unix⽤户，它是'posix'。
os.getcwd:得到当前⼯作⽬录，即当前python脚本⼯作的⽬录路径。
os.getenv()和os.putenv:分别⽤来读取和设置环境变量
os.listdir():返回指定⽬录下的所有⽂件和⽬录名
os.remove(file):删除⼀个⽂件
os.stat（file）:获得⽂件属性
os.chmod(file):修改⽂件权限和时间戳
os.mkdir(name):创建⽬录
os.rmdir(name):删除⽬录
os.removedirs（r“c：\python”）:删除多个⽬录
os.system():运⾏shell命令
os.exit():终⽌当前进程
os.linesep:给出当前平台的⾏终⽌符。例如，Windows使⽤'\r\n'，Linux使⽤'\n'⽽Mac使⽤'\r'
os.path.split():返回⼀个路径的⽬录名和⽂件名
os.path.isfile()和os.path.isdir()分别检验给出的路径是⼀个⽬录还是⽂件
os.path.existe():检验给出的路径是否真的存在
os.listdir(dirname):列出dirname下的⽬录和⽂件
os.getcwd():获得当前⼯作⽬录
os.curdir:返回当前⽬录（'.'）
os.chdir(dirname):改变⼯作⽬录到dirname
os.path.isdir(name):判断name是不是⽬录，不是⽬录就返回false
os.path.isfile(name):判断name这个⽂件是否存在，不存在返回false
os.path.exists(name):判断是否存在⽂件或⽬录name
os.path.getsize(name):或得⽂件⼤⼩，如果name是⽬录返回0L
os.path.abspath(name):获得绝对路径
os.path.isabs():判断是否为绝对路径
os.path.normpath(path):规范path字符串形式
os.path.split(name):分割⽂件名与⽬录（事实上，如果你完全使⽤⽬录，它也会将最后⼀个⽬录作为⽂件名⽽分离，同时它不会判断⽂件或⽬录是否存在）
os.path.splitext():分离⽂件名和扩展名
os.path.join(path,name):连接⽬录与⽂件名或⽬录
os.path.basename(path):返回⽂件名
os.path.dirname(path):返回⽂件路径

AssertionError 断⾔语句（assert）失败
AttributeError 尝试访问未知的对象属性
EOFError ⽤户输⼊⽂件末尾标志EOF（Ctrl+d）
ImportError 导⼊模块失败的时候
IndexError 索引超出序列的范围
KeyError 字典中查找⼀个不存在的关键字
KeyboardInterrupt ⽤户输⼊中断键（Ctrl+c）
MemoryError 内存溢出（可通过删除对象释放内存）
NameError 尝试访问⼀个不存在的变量
NotImplementedError 尚未实现的⽅法
OSError 操作系统产⽣的异常（例如打开⼀个不存在的⽂件）
OverflowError 数值运算超出最⼤限制
RuntimeError ⼀般的运⾏时错误
StopIteration 迭代器没有更多的值
SyntaxError Python的语法错误
IndentationError 缩进错误
TabError Tab和空格混合使⽤
SystemError Python编译器系统错误
SystemExit Python编译器进程被关闭
TypeError 不同类型间的⽆效操作
UnboundLocalError 访问⼀个未初始化的本地变量（NameError的⼦类）
ValueError 传⼊⽆效的参数
ZeroDivisionError 除数为零

# 1. 连接数据库，
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='redhat',
    db='helloTest',
    charset='utf8',
       # autocommit=True,    # 如果插入数据，， 是否自动提交? 和conn.commit()功能一致。
)
# ****python, 必须有一个游标对象， 用来给数据库发送sql语句， 并执行的.
# 2. 创建游标对象，
cur = conn.cursor()
# 3. 对于数据库进行增删改查
# 1). ************************创建数据表**********************************
try:
    create_sqli = "create table hello (id int, name varchar(30));"
    cur.execute(create_sqli)
except Exception as e:
    print("创建数据表失败:", e)
else:
    print("创建数据表成功;")
## 2). *********************插入数据****************************
try:
    insert_sqli = "insert into hello values(2, 'fensi');"
    cur.execute(insert_sqli)
except Exception as e:
    print("插入数据失败:", e)
else:
    # 如果是插入数据， 一定要提交数据， 不然数据库中找不到要插入的数据;
    conn.commit()
    print("插入数据成功;")
# 3). *********************插入多条数据****************************
try:
    info = [(i, "westos%s" %(i)) for i in range(100)]

    # *********************第一种方式********************
    # %s必须手动添加一个字符串， 否则就是一个变量名， 会报错.
    insert_sqli = "insert into hello values(%d, '%s');"
    for item in info:
        print('insert语句:', insert_sqli %item)
        cur.execute(insert_sqli %item)

     # *********************第二种方式********************
    insert_sqli = "insert into hello values(%s, %s);"
     cur.executemany(insert_sqli, info )
except Exception as e:
    print("插入多条数据失败:", e)
else:
    # 如果是插入数据， 一定要提交数据， 不然数据库中找不到要插入的数据;
    conn.commit()
    print("插入多条数据成功;")
# 4). **************************数据库查询*****************************
sqli = "select * from hello;"
result = cur.execute(sqli)  # 默认不返回查询结果集， 返回数据记录数。
print(result)
print(cur.fetchone())     # 1). 获取下一个查询结果集;
print(cur.fetchone())
print(cur.fetchone())
print(cur.fetchmany(4))   # 2). 获取制定个数个查询结果集；
info = cur.fetchall()     # 3). 获取所有的查询结果
print(info)
print(len(info))
print(cur.rowcount)       # 4). 返回执行sql语句影响的行数
#  5). 移动游标指针
print(cur.fetchmany(3))
print("正在移动指针到最开始......")
cur.scroll(0, 'absolute')
print(cur.fetchmany(3))
print("正在移动指针到倒数第2个......")
print(cur.fetchall())    # 移动到最后
cur.scroll(-2, mode='relative')
print(cur.fetchall())
# 4. 关闭游标
cur.close()
# 5. 关闭连接
conn.close()

#首先导入所需要的模块
import time
import pymysql
#然后进入主程序部分：此部分用with语句编写（with语句实现的效果是: with语句执行结束， 如果成功， 则提交改变的数据， 如果不成功， 则回滚.）
conn = pymysql.connect(
    host='localhost',
    user='root',
    password='redhat',
    db='helloTest',
    charset='utf8',
    # autocommit=True,    # 如果插入数据，， 是否自动提交? 和conn.commit()功能一致。
) 	#连接数据库
with conn:	#主程序with语句部分
    # ****** 判断是否连接? 
    print(conn.open)  # True
    # 2. 创建游标对象，
    cur = conn.cursor()
    # 3).
    sqli = "select * from hello;"
    result = cur.execute(sqli)  # 默认不返回查询结果集， 返回数据记录数。
    # 显示每列的详细信息
    des = cur.description
    print("表的描述:", des)
	# 获取表头
    print("表头:", ",".join([item[0] for item in des]))
    cur.close() 	#关闭游标，with语句内部
 conn.close()	#关闭指针，with语句外部
print("with语句之外:", conn.open)   # 正确情况下会是False

#银行转账系统考虑因素主要包括：
#1). 判断两个银行卡号是否存在?
#2). 判断source_id是否有足够的钱？
#3). source_id扣钱
#4). target_id加钱
#测试时，首先在数据库中构造数据表bankData,在数据表中添加用户信息（包括用户帐号和账户内金额）
import pymysql
class TransferMoney(object):
    # 构造方法
    def __init__(self, conn):
        self.conn = conn
        self.cur = conn.cursor()
    def transfer(self, source_id, target_id, money):
		if not self.check_account_avaialbe(source_id):
            raise  Exception("账户不存在")
        if not self.check_account_avaialbe(target_id):
            raise  Exception("账户不存在")
        if self.has_enough_money(source_id, money):
            try:
                self.reduce_money(source_id, money)
                self.add_money(target_id, money)
            except Exception as e:
                print("转账失败:", e)
                self.conn.rollback()
            else:
                self.conn.commit()
                print("%s给%s转账%s金额成功" % (source_id, target_id, money))
                
    def check_account_avaialbe(self, acc_id):
        """判断帐号是否存在， 传递的参数是银行卡号的id"""
        select_sqli = "select * from bankData where id=%d;" % (acc_id)
        print("execute sql:", select_sqli)
        res_count = self.cur.execute(select_sqli)
        if res_count == 1:
            return True
        else:
            # raise  Exception("账户%s不存在" %(acc_id))
            return False
            
    def has_enough_money(self, acc_id, money):
        """判断acc_id账户上金额> money"""
        # 查找acc_id存储金额?
        select_sqli = "select money from bankData where id=%d;" % (acc_id)
        print("execute sql:", select_sqli)
        self.cur.execute(select_sqli)  # ((1, 500), )
        # 获取查询到的金额钱数;
        acc_money = self.cur.fetchone()[0]
        # 判断
        if acc_money >= money:
            return True
        else:
            return False

    def add_money(self, acc_id, money):
        update_sqli = "update bankData set money=money+%d  where id=%d" % (money, acc_id)
        print("add money:", update_sqli)
        self.cur.execute(update_sqli)

    def reduce_money(self, acc_id, money):
        update_sqli = "update bankData set money=money-%d  where id=%d" % (money, acc_id)
        print("reduce money:", update_sqli)
        self.cur.execute(update_sqli)
    # 析构方法
    def __del__(self):
        self.cur.close()
        self.conn.close()
        
if __name__ == '__main__':
    # 1. 连接数据库，
    conn = pymysql.connect(
        host='localhost',
        user='root',
        password='redhat',
        db='helloTest',
        charset='utf8',
        autocommit=True,    # 如果插入数据，， 是否自动提交? 和conn.commit()功能一致。
    )
    trans = TransferMoney(conn)   
    trans.transfer(13997, 13998, 200)	#账户13997向13998转账200

import random
import time


def time_count(func):
    def wrap(*args, **kwargs):
        time_flag = time.time()
        temp_result = func(*args, **kwargs)
        print(("time cost:", time.time() - time_flag))
        return temp_result

    return wrap


@time_count
def loop_time(x, y):
    result = 0
    for i in range(x, y):
        time.sleep(random.choice((0.1, 0.2, 0.3)))
        result = x + y
    return result

if __name__ == '__main__':
    print((loop_time(1, 2)))

import paramiko

# 创建SSHClient实例对象
ssh = paramiko.SSHClient()
# 调用方法，标识没有远程机器的公钥，允许访问
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 连接远程机器 地址端口用户名密码
ssh.connect("192.168.13.128",22,"root","111111")
# 创建目录
ssh.exec_command("pwd")
ssh.exec_command("mkdir test")
ssh.exec_command("cd test")
stdin,stdout,stderr = ssh.exec_command("pwd")
print(stdout.read())
ssh.close()

import paramiko
 
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect('192.168.13.128',22,'root','111111')
stdin,stdout,stderr = ssh.exec_command('ls')
print(stdout.read())
sftp = ssh.open_sftp()
sftp.put(r'E:\Downloads\test.py','/home/test.py')
stdin,stdout,stderr = ssh.exec_command('ls;cd /home;ls;pwd')
print(stdout.read())

from jsoncompare import jsoncompare as json_comp

json_comp.long = int
json_comp.unicode = str
json_comp.xrange = range


a = [
  {
    "Key": "managed",
    "Value": "yes"
  }
]

b = [
  {
    "Key": "managed",
    "Value": "No"
  }
]

# Compare respecting each array's order
json_comp.are_same(a, b)

print(json_comp.are_same(a, b)[1])