Category: python

Python’da MSSQL veritabanında SELECT sorgusu çalıştırmak için pyodbc kütüphanesini kullanabilirsiniz. İşte bir örnek:

import pyodbc

# Bağlantı bilgilerini ayarlayın
server = 'your_server_name'
database = 'your_database_name'
username = 'your_username'
password = 'your_password'

# Bağlantı dizesini oluşturun
conn_str = f'DRIVER={{SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password}'

# Veritabanına bağlan
conn = pyodbc.connect(conn_str)

# Bağlantı üzerinden bir cursor oluşturun
cursor = conn.cursor()

# SELECT sorgusu çalıştırın
cursor.execute('SELECT * FROM your_table')

# Sonuçları alın
results = cursor.fetchall()

# Sonuçları işleyin
for row in results:
    print(row)

# Cursor ve bağlantıyı kapatın
cursor.close()
conn.close()

Yukarıdaki örnekte, pyodbc kütüphanesini kullanarak MSSQL veritabanında SELECT sorgusu çalıştırılmaktadır. Bağlantı bilgilerini (server, database, username, password) kendi MSSQL sunucu ve veritabanı bilgilerinizle değiştirin.

cursor.execute() yöntemiyle SELECT sorgusu çalıştırılır ve fetchall() metoduyla sonuçlar alınır. Sonuçlar, results değişkenine atanır ve ardından işlenebilir.

Bu örnekte, SELECT sorgusu SELECT * FROM your_table olarak verilmiştir. your_table yerine kendi tablo adınızı kullanın. Eğer sorgunuzda filtreleme veya sıralama gibi ek parametreler gerekiyorsa, SQL sorgusunu buna göre düzenleyebilirsiniz.

Son olarak, cursor.close() ve conn.close() yöntemleriyle cursor ve bağlantıyı kapatmayı unutmayın.

Python’da Microsoft SQL Server veritabanına bağlanmak için pyodbc kütüphanesini kullanabilirsiniz. Aşağıda, pyodbc kullanarak MSSQL bağlantısı kurmanın örnek bir kodunu bulabilirsiniz:

import pyodbc

# Bağlantı bilgilerini ayarlayın
server = 'your_server_name'
database = 'your_database_name'
username = 'your_username'
password = 'your_password'

# Bağlantı dizesini oluşturun
conn_str = f'DRIVER={{SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password}'

# Veritabanına bağlan
conn = pyodbc.connect(conn_str)

# Bağlantı üzerinden bir cursor oluşturun
cursor = conn.cursor()

# Örnek bir SQL sorgusu çalıştırın
cursor.execute('SELECT * FROM your_table')

# Sonuçları alın
results = cursor.fetchall()

# Sonuçları işleyin
for row in results:
    print(row)

# Cursor ve bağlantıyı kapatın
cursor.close()
conn.close()

Yukarıdaki örnekte, pyodbc kütüphanesini kullanarak MSSQL veritabanına bağlantı kurulur. Bağlantı bilgilerini (server, database, username, password) kendi MSSQL sunucu ve veritabanı bilgilerinizle değiştirin.

Bağlantı dizesi conn_str oluşturulurken f-string formatı kullanılarak bağlantı bilgileri yerleştirilir. Bağlantı dizesi DRIVER={{SQL Server}};SERVER={server};DATABASE={database};UID={username};PWD={password} formatındadır.

Bağlantı başarılı olduktan sonra bir cursor oluşturulur. cursor.execute() yöntemiyle SQL sorgusu çalıştırılır ve fetchall() metoduyla sonuçlar alınır.

Sonuçları işleyebilir ve gerekli diğer SQL sorgularını bu bağlantı üzerinden çalıştırabilirsiniz.

Son olarak, cursor.close() ve conn.close() yöntemleriyle cursor ve bağlantıyı kapatmayı unutmayın.

import mysql.connector
import schedule
import time

def check_and_process_data():
    # Veritabanı bağlantısı
    mydb = mysql.connector.connect(
      host="localhost",
      user="kullanici_adi",
      password="sifre",
      database="veritabani_adi"
    )
    
    # Bağlantı kontrolü
    if mydb.is_connected():
        print("Veritabanına başarıyla bağlandı.")
    
    # Veri kontrolü ve işlem
    mycursor = mydb.cursor()
    mycursor.execute("SELECT deger FROM tablo_adi")
    result = mycursor.fetchone()
    
    if result[0] == 0:
        # İşlem yapılacak kodlar buraya gelecek
        print("Veri 0'a eşit, işlem yapılıyor...")
    else:
        print("Veri 0'a eşit değil, işlem yapılmayacak.")
    
    # Veritabanı bağlantısını kapatma
    mydb.close()

# Her 10 saniyede bir veri kontrolü yap
schedule.every(10).seconds.do(check_and_process_data)

while True:
    schedule.run_pending()
    time.sleep(1)

Yukarıdaki örnekte, schedule modülü kullanılarak check_and_process_data adlı bir fonksiyon belirli aralıklarla çağrılır. Bu örnekte her 10 saniyede bir veri kontrolü yapmak için schedule.every(10).seconds.do(check_and_process_data) kullanılır.

check_and_process_data fonksiyonu, veritabanına bağlanır, veriyi kontrol eder ve gerekli işlemleri yapar. Bu fonksiyonu kendi işlemlerinize göre düzenleyebilirsiniz.

Sonra, while True döngüsü ile schedule.run_pending() fonksiyonu çağrılır ve program belirli aralıklarla veri kontrolü yapmaya devam eder. time.sleep(1) fonksiyonu, döngünün her bir turunda 1 saniye bekletme işlemi gerçekleştirir.

Bu şekilde, program belirli aralıklarla veri kontrolü yapacak ve 0 olan veriler için belirlediğiniz işlemi gerçekleştirecektir.

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT * FROM your_table"
cursor.execute(query)

result = cursor.fetchall()

cursor.close()
cnx.close()

print(result)

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT * FROM your_table WHERE your_column = 0 LIMIT 1"
cursor.execute(query)

result = cursor.fetchone()

cursor.close()
cnx.close()

print(result)

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

query = "SELECT your_column FROM your_table WHERE ..."
cursor.execute(query)
result = cursor.fetchone()
number = result[0]  # Sayıyı alın

for i in range(number):
    print("Döngü adımı:", i+1)
    # Döngü işlemlerini burada gerçekleştirin

cursor.close()
cnx.close()

import mysql.connector

config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database'
}

cnx = mysql.connector.connect(**config)
cursor = cnx.cursor()

name = "John Doe"  # Aktarmak istediğiniz değişkenin içeriği

query = "INSERT INTO your_table (column_name) VALUES (%s)"
cursor.execute(query, (name,))

cnx.commit()

cursor.close()
cnx.close()

Python programını yeniden başlatmak için aşağıdaki yöntemleri kullanabilirsiniz:

1. exit() Kullanma:

pythonCopy codeimport sys

# Programın yeniden başlatılması gerektiği bir noktada
sys.exit()

sys.exit() çağrısı, programın anında sonlanmasını sağlar. Program sonlandığında, Python yürütme ortamından çıkar ve program otomatik olarak yeniden başlatılmaz.

2. os.execv() Kullanma:

pythonCopy codeimport os
import sys

# Programın yeniden başlatılması gerektiği bir noktada
python = sys.executable
os.execl(python, python, *sys.argv)

Bu yöntem, os.execv() fonksiyonunu kullanarak Python yürütülebilir dosyasını (interpreter) tekrar çağırmak suretiyle programı yeniden başlatır. sys.executable, çalışan Python yürütücüsünün tam yolunu temsil eder.

Bu yöntemler programı doğrudan yeniden başlatır. Ancak, programın mevcut durumunu ve değişkenlerini korumazlar. Eğer mevcut durumu korumak ve değişkenleri aktarmak isterseniz, başka bir yöntem kullanmanız gerekebilir.

3. Subprocess Modülünü Kullanma:

pythonCopy codeimport sys
import subprocess

# Programın yeniden başlatılması gerektiği bir noktada
subprocess.call([sys.executable] + sys.argv)

Bu yöntemde, subprocess.call() fonksiyonu kullanılarak ayrı bir süreç başlatılır ve mevcut Python programını yeniden çağırır. sys.argv, programın komut satırı argümanlarını temsil eder.

Bu yöntem, programı yeniden başlatırken mevcut durumu ve değişkenleri korumaya yardımcı olur.

Hangi yöntemi kullanacağınız, ihtiyaçlarınıza ve programınızın gereksinimlerine bağlıdır. İlgili noktada uygun olan yöntemi seçerek programınızı yeniden başlatabilirsiniz.

<?php

// API erişim bilgileri
$apiUrl = 'https://example.com:2083/execute/StatCollector/get_service_statuses';
$apiKey = 'API_ANAHTARINIZ';

// cURL isteği oluşturma
$curl = curl_init();

curl_setopt_array($curl, array(
  CURLOPT_URL => $apiUrl,
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => '',
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 0,
  CURLOPT_FOLLOWLOCATION => true,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => 'POST',
  CURLOPT_POSTFIELDS => '[{ "module": "stat-collector", "function": "get_service_statuses", "apiversion": 3, "args": {} }]',
  CURLOPT_HTTPHEADER => array(
    'Authorization: cpanel ' . $apiKey,
    'Content-Type: application/json'
  ),
));

// API isteğini gerçekleştirme
$response = curl_exec($curl);

// cURL işlemini kapatma
curl_close($curl);

// Yanıtı görüntüleme
echo $response;
?>

<?php
// HP switch'in IP adresini ve yönetici kullanıcı adı/şifresini tanımlayın
$switchIP = '192.168.0.1';
$username = 'admin';
$password = 'password';

// Komutları içeren bir dizi oluşturun
$commands = [
    'show interfaces',
    'show vlan',
    'show running-config'
];

// Komutları HP switch'e gönderen bir fonksiyon tanımlayın
function sendCommandsToSwitch($switchIP, $username, $password, $commands) {
    // SSH bağlantısını kurun
    $connection = ssh2_connect($switchIP, 22);
    if (!$connection) {
        die('SSH bağlantısı kurulamadı.');
    }

    // SSH kimlik doğrulamasını gerçekleştirin
    if (!ssh2_auth_password($connection, $username, $password)) {
        die('Kimlik doğrulaması başarısız.');
    }

    // Komutları işleyin
    foreach ($commands as $command) {
        // SSH oturumu başlatın
        $shell = ssh2_shell($connection, 'vt102', null, 80, 40, SSH2_TERM_UNIT_CHARS);
        if (!$shell) {
            die('SSH oturumu başlatılamadı.');
        }

        // Komutu gönderin
        fwrite($shell, $command . PHP_EOL);

        // Çıktıyı alın
        $output = '';
        while ($line = fgets($shell)) {
            $output .= $line;
        }

        // Çıktıyı ekrana yazdırın veya başka bir şekilde işleyin
        echo 'Komut: ' . $command . PHP_EOL;
        echo 'Çıktı: ' . $output . PHP_EOL;

        // SSH oturumunu kapatın
        fclose($shell);
    }

    // SSH bağlantısını kapatın
    ssh2_disconnect($connection);
}

// Komutları switch'e gönderin
sendCommandsToSwitch($switchIP, $username, $password, $commands);
?>